Kunni
|
a16abd5d24
|
[FLINK-36913][pipeline-connector][kafka] Introduce option to define custom mapping from upstream table id to downstream topic name
This closes #3805
|
1 month ago |
yuxiqian
|
e2b8f70e0d
|
[FLINK-37124][build] Simplify logs in test cases to avoid flooding GHA outputs
This closes #3860
|
1 month ago |
MOBIN
|
a130718c96
|
[FLINK-36858][pipeline-connector][kafka] Fix JsonRowDataSerializationSchema compatibility issue with Flink 1.20
This closes #3784
Co-authored-by: Leonard Xu <xbjtdcq@gmail.com>
|
1 month ago |
|
Kunni
|
28985db062
|
[FLINK-36877][pipeline-connector/kafka] Correct canal-json output for delete record
This closes #3788
|
2 months ago |
|
yuxiqian
|
6d21941661
|
[hotfix] Fix Java 11 target compatibility & add tests (#3633)
* [hotfix] Fix Java 11 target compatibility
Signed-off-by: yuxiqian <34335406+yuxiqian@users.noreply.github.com>
# Conflicts:
# .github/workflows/flink_cdc_java_8.yml
# .github/workflows/flink_cdc_migration_test_base.yml
# pom.xml
* fix: clarify GiHub workflow names
Signed-off-by: yuxiqian <34335406+yuxiqian@users.noreply.github.com>
---------
Signed-off-by: yuxiqian <34335406+yuxiqian@users.noreply.github.com>
|
2 months ago |
Hang Ruan
|
fd82126c7d
|
[FLINK-36878][pipeline-connector][kafka] Shade org.apache.kafka with org.apache.flink.kafka.shaded.org.apache.kafka instead of cdc path
This closes #3790.
|
3 months ago |
ConradJam
|
dd79a02f0f
|
[FLINK-36586][build] Update flink version to 1.19 (#3660)
Co-authored-by: ConradJam <czy006@apache.com>
Co-authored-by: Hang Ruan <ruanhang1993@hotmail.com>
|
3 months ago |
|
Kunni
|
ecfee702dc
|
[FLINK-36560][pipeline-connector][paimon] Fix the issue that timestamp_ltz field is not correctly converted
This closes #3648.
|
4 months ago |
|
Kunni
|
f24399cf5a
|
[FLINK-36211][pipeline-connector/kafka] shade org.apache.flink.streaming.connectors.kafka to avoid conflict with flink-connector-kafka jar. (#3595)
|
4 months ago |
|
Kunni
|
0470fdbbc1
|
[FLINK-36082][pipeline-connector][kafka] Fix lamda NotSerializableException in KafkaDataSink
This closes #3549
|
6 months ago |
|
Kunni
|
e0d6d1d1a8
|
[FLINK-35442][cdc-connect][kafka] add key.format and partition.strategy option to make sure the same record sending to the same partition. (#3522)
|
7 months ago |
|
Kunni
|
9d6154f123
|
[FLINK-35791][kafka] Add database and table info of Canal / Debezium json format for Kafka sink (#3461)
|
7 months ago |
|
yuxiqian
|
5ed9e05bdf
|
[FLINK-35242][cdc-common][cdc-runtime] Support TRY_EVOLVE and LENIENT schema evolution behavior
This closes #3339.
|
7 months ago |
|
yux
|
2bd2e4ce24
|
[FLINK-35121][common] Adds validation for pipeline definition options
|
9 months ago |
joyCurry30
|
0e8b2c7cc5
|
[FLINK-35430][cdc-connector][kafka] Pass the time zone infor to JsonSerializationSchema
This closes #3359.
|
9 months ago |
|
Kunni
|
ec643c9dd7
|
[FLINK-35235][pipeline-connector][kafka] Fix missing dependencies in the uber jar of Kafka pipeline sink
|
10 months ago |
|
Kunni
|
253ef9256b
|
[pipeline-connector][kafka] Add kafka pipeline data sink connector. (#2938)
|
10 months ago |