241eb03a74
[FLINK-35868][cdc-connector][mongodb] Bump dependency version to support MongoDB 7.0
...
This closes #3489 .
7 months ago
91fc7bb506
[FLINK-35740][cdc-connector][mysql] Allow column as chunk key even it's not primary key
...
This closes #3448 .
7 months ago
ea71b2302d
[FLINK-35874][cdc-connector][mysql] Check pureBinlogPhaseTables set before call getBinlogPosition method
...
This closes #3488 .
7 months ago
313bace106
[minor][doc][cdc-connector][oracle] Update OracleSchema#getTableSchema doc description
...
This closes #3443 .
7 months ago
c5f391cf6a
[FLINK-35865][base] Support Byte and Short in ObjectUtils ( #3481 )
7 months ago
332e1f330d
[minor][cdc-connector][sqlserver] Fix some typos ( #3421 )
7 months ago
9a97182fbb
[minor][cdc-connector][mysql] Code optimization for constants
...
This closes #3385
7 months ago
2d50e43137
[minor][cdc-connector][postgres] PostgresDialect removes useless code
...
This closes #3416 .
7 months ago
94a0415475
[FLINK-34883] Fix postgres uuid column as PK ( #3282 )
...
* [FLINK-34883] Fix postgres uuid column as PK
* [FLINK-34883] Fix column comment.
8 months ago
a2539f5cfa
[hotfix][docs][postgres] Remove unsupported erroneous example code
...
This closes #3464
8 months ago
2d1eb0aff1
[FLINK-34990][cdc-connector][oracle] Oracle cdc support newly add table ( #3203 )
...
* [cdc-connector][oracle] Oracle cdc support newly add table
* [cdc-connector][oracle] Fix code style
* [cdc-connector][oracle] Address comment
8 months ago
302a691225
[FLINK-35354] Support host mapping in Flink tikv cdc ( #3336 )
...
* [FLINK-35337][cdc] Keep up with the latest version of tikv client
* [FLINK-35354]Support host mapping in Flink tikv cdc
* [FLINK-35354] Add doc for host mapping feature
* [FLINK-35354] fixed annotation import
8 months ago
80920aaa28
[FLINK-35297][mysql] Add validation for option connect.timeout because of HikariConfig limitation ( #3295 )
8 months ago
2bd2e4ce24
[FLINK-35121][common] Adds validation for pipeline definition options
9 months ago
c958daf8ab
[FLINK-35540][cdc-common] Fix table missed when database and table are with the same name
...
This closes #3396 .
9 months ago
17ff659ff7
[hotfix][build] Remove test-jar from parent pom and only add to necessary modules
...
This closes #3397 .
Co-authored-by: Qingsheng Ren <renqschn@gmail.com>
9 months ago
e2ccc836a0
[FLINK-34908][pipeline-connector][doris] Fix MySQL to doris pipeline will lose precision for timestamp type
...
This closes #3207 .
9 months ago
1a360635c7
[FLINK-35092][cdc][starrocks] Add starrocks integration test cases
9 months ago
8eb7e53965
[FLINK-35120][doris] Add Doris integration test cases
9 months ago
8a7fdd5ae3
[minor][cdc-connector][paimon] Remove duplicate interface implements
9 months ago
0214166049
[FLINK-35325][cdc-connector][paimon] Support specify column order when adding new columns to a table
...
This closes #3323 .
9 months ago
5b28d1a579
[FLINK-35129][postgres] Introduce scan.lsn-commit.checkpoints-num-delay option to control LSN offset commit lazily
...
This close #3349 .
9 months ago
0e8b2c7cc5
[FLINK-35430][cdc-connector][kafka] Pass the time zone infor to JsonSerializationSchema
...
This closes #3359 .
9 months ago
19c382c0f2
[FLINK-35409][cdc][mysql] Request more splits if all splits are filtered from addSplits method
...
This closes #3342 .
9 months ago
b2cb30f240
[FLINK-35408][mysql] Introduce 30 minutes tolerance when validate the time-zone setting
...
This closes #3341 .
9 months ago
6350eec66c
[FLINK-35301][cdc] Avoid deadlock when loading driver classes
...
This closes #3300 .
9 months ago
18b0627e34
[FLINK-35295][mysql] Improve jdbc connection pool initialization failure message
...
This closes #3293 .
9 months ago
bddcaae784
[FLINK-35294][mysql] Use source config to check if the filter should be applied in timestamp starting mode
...
This closes #3291 .
9 months ago
8e8fd304af
[FLINK-35298][cdc][metrics] Improve the fetch delay metrics
...
This closes #3298 .
9 months ago
fa6e7ea512
[FLINK-35245][cdc-connector][tidb] Add metrics for flink-connector-tidb-cdc
10 months ago
a7cb46f762
[FLINK-35274][cdc-connector][db2] Fix occasional failure issue with Flink CDC Db2 UT
10 months ago
002b16ed4e
[FLINK-35244][cdc-connector][tidb] Correct the package for flink-connector-tidb-cdc test
10 months ago
ec643c9dd7
[FLINK-35235][pipeline-connector][kafka] Fix missing dependencies in the uber jar of Kafka pipeline sink
10 months ago
6232d84052
[FLINK-35173][cdc][mysql] Debezium custom time serializer for MySQL connector ( #3240 )
10 months ago
05281e5d6f
[FLINK-34639][cdc][oceanbase] Support debezium deserializer in OceanBase source connector ( #3124 )
10 months ago
bdca0e328b
[FLINK-35128][cdc-connector][cdc-base] Re-calculate the starting changelog offset after the new table added ( #3230 )
10 months ago
ddf557c8e1
[tests][cdc-connector][db2] Improve the DB2 tests
...
This closes #2870
10 months ago
8deddab6eb
[minor][cdc-connector][db2] Fix typos and improve the code style
10 months ago
3385ae8fbc
[cdc-connector][db2] Db2 support incremental source
10 months ago
ef2eece256
[pipeline-connector][paimon] add paimon pipeline data sink connector. ( #2916 )
10 months ago
01ec7da989
[FLINK-35055][cdc] Exclude connector dependencies with questionable licenses from fat jar packages ( #3212 )
10 months ago
253ef9256b
[pipeline-connector][kafka] Add kafka pipeline data sink connector. ( #2938 )
10 months ago
5e52d8620c
[FLINK-35102][cdc][doris-sink] Correct Doris connector varchar type mapping
...
This closes #3224 .
10 months ago
0d797a6021
[FLINK-34903][cdc][mysql] Add mysql-pipeline-connector with tables.exclude option to exclude unnecessary tables ( #3186 )
10 months ago
d4ed7db8dc
[FLINK-35127][cdc][values] Remove HybridSource from ValuesSource to avoid CI failure. ( #3237 )
10 months ago
0562e35da7
[FLINK-35079][cdc-connector][mongo] Fallback to timestamp startup mode when resume token has expired
11 months ago
48ca8623bb
[FLINK-34634][cdc-base][mysql] Fix that Restarting the job will not read the changelog anymore if it stops before the synchronization of meta information is complete and some table is removed ( #3134 )
11 months ago
af7665d338
[FLINK-34689][MySQL][Feature] check binlog_row_value_options ( #3148 )
11 months ago
1b0b9f868d
[minor][cdc-connector][mongo] Fix warning during MongoDB tests ( #3210 )
11 months ago
025653d772
[hotfix] run mvn spotless to fix code style violations. ( #3219 )
11 months ago
yuxiqian
SeungMin
Zhongmin Qiao
ChengJie1053
gongzhongqiang
Xin Gong
Joao Boto
skylines
ouyangwulin
Shawn Huang
North Lin
joyCurry30
Muhammet Orazov
Xie Yi
Kunni
ConradJam
He Wang
Hongshun Wang
Leonard Xu
Thorne