Commit Graph

99 Commits (release-3.1)

Author SHA1 Message Date
ConradJam f476a5b1dd
[FLINK-35592][cdc] Fix MysqlDebeziumTimeConverter miss timezone convert to timestamp (#3380) 8 months ago
yux 5650ee29c6
[FLINK-35294][mysql] Use source config to check if the filter should be applied in timestamp starting mode
This closes  #3373.
8 months ago
yux 84ae0dc453
[FLINK-35301][cdc] Avoid deadlock when loading driver classes
This closes  #3372.
8 months ago
yux 536f707eb7
[FLINK-35408][mysql] Introduce 30 minutes tolerance when validate the time-zone setting
This closes  #3371.
8 months ago
yux e18e7a2523
[FLINK-35295][mysql] Improve jdbc connection pool initialization failure message 8 months ago
Qingsheng Ren e452d66b3b [FLINK-35309][cdc] Resolve license and NOTICE issues in the project
Co-authored-by: GOODBOY008 <gongzhongqiang@apache.org>
9 months ago
Xin Gong d556f29475
[FLINK-35274][cdc-connector][db2] Fix occasional failure issue with Flink CDC Db2 UT 9 months ago
Qingsheng Ren 38a1782ecc [hotfix] Remove test-jar from parent pom and only add to necessary modules 10 months ago
ConradJam 90511b3a65
[FLINK-35173][cdc][mysql] Debezium custom time serializer for MySQL connector (#3240) (#3264) 10 months ago
He Wang 23979a716d
[FLINK-34639][cdc][oceanbase] Support debezium deserializer in OceanBase source connector (#3124) (#3259) 10 months ago
Hongshun Wang aa2ffd9c27
[FLINK-35128][cdc-connector][cdc-base] Re-calculate the starting changelog offset after the new table added (#3230) (#3257) 10 months ago
gong 5b6e893e94 [cdc-connector][db2] Db2 support incremental source 10 months ago
yux 01ec7da989
[FLINK-35055][cdc] Exclude connector dependencies with questionable licenses from fat jar packages (#3212) 10 months ago
yuxiqian 0562e35da7
[FLINK-35079][cdc-connector][mongo] Fallback to timestamp startup mode when resume token has expired 10 months ago
Hongshun Wang 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) 10 months ago
L af7665d338
[FLINK-34689][MySQL][Feature] check binlog_row_value_options (#3148) 10 months ago
yuxiqian 1b0b9f868d
[minor][cdc-connector][mongo] Fix warning during MongoDB tests (#3210) 10 months ago
shikai93 80d461b1b8
[MySQL] Fix for DBZ-7037 and #2217 to not clear tableMapEventByTableId for fake Rotates Event (#3065) 10 months ago
wenmo a35b8dd44c [build] Optimize pom to solve the CI error 10 months ago
Paul Lin f7f248cda1
[build] fix inconsistent Kafka shading among cdc connectors (#2988) 11 months ago
xleoken 5f4f86fb31
[hotfix] Change old com.ververica dependencies to org.apache.flink (#3110) 11 months ago
Xin Gong 14b81dc6ec
[FLINK-34715][cdc][cdc-connector][mysql] Correctly close BinlogSplitReader in MySQL UTCase
This closes #3161.
11 months ago
Kunni 26eb6a99b9
[hotfix][cdc][build] Include cdc-common module when shaded for module flink-sql-connector-mysql-cdc 11 months ago
Hang Ruan 86272bf102
[FLINK-34183][cdc][license] Update NOTICE files (#3107) 11 months ago
Hang Ruan e10c8691ad
[FLINK-34584][cdc][build] Rename package from com.ververica to org.apache.flink
This closes #3089.
11 months ago
Hang Ruan eeb4bab92d [FLINK-34184][cdc][license] Update Copyright from Ververica to Apache 11 months ago
e-mhui 6da9684999
[cdc-connector][oracle] Use database name in upper case at the snapshot phase to fix fetching two different db name for the same table at the snapshot phase and incremental phase(#2088) 12 months ago
e-mhui ea7b0e8dbb
[cdc-base] Support to parse Oracle/SqlServer/PostgresSQL CDC schema change events (#2315) 12 months ago
Hongshun Wang a2ad627fed [cdc-connector][mongodb] Expose capture newly added tables ability to Mongodb CDC source 12 months ago
Hongshun Wang 03a287a9c2 [cdc-connector][postgres] Expose capture newly added tables ability to Postgres CDC source 12 months ago
Hongshun Wang 1eeda75eaa [cdc-connector][cdc-base] Support capture newly added tables with un-blocking stream read for CDC Framework(#3024) 12 months ago
Yaroslav Tkachenko 1562bc29a3 [cdc-base] Support Scan Newly Added Tables feature 12 months ago
Hongshun Wang 0ca718c31f
[cdc-connector][oracle] Expose SNAPSHOT_ONLY mode for Oracle CDC Source (#3005) 1 year ago
gongzhongqiang d058102c5c
[cdc-connector][oracle]Add oracle 21 version to OracleValidator (#3054) 1 year ago
yuxiqian 82ccf00e6a
[hotfix][cdc-connector][mongodb] Fix scanFullChangelog requires all collections 1 year ago
Hongshun Wang 7ea197242f
[debezium] Upgrade to Debezium 1.9.8.Final(#3033) (#3034) 1 year ago
Xin Gong 10e542c3ff
[cdc-connector][sqlserver] sqlserver support use specific chunk column as a split key (#2972)
This closes #2971.
1 year ago
Hongshun Wang 3be3417de2
[cdc-connector][postgres] Fix potential PostgresSQL database connection leak (#3013)
This closes #2980.
1 year ago
Xin Gong 20e44e6966
[cdc-connector][oracle] Oracle supports user specific chunk column (#2976)
This closes #2973.
1 year ago
Hongshun Wang a2d36a892e
[cdc-connector][mongodb][hotfix] Stop executing log reading in MongoDBStreamFetchTask#close (#3029)
This closes #3029.
1 year ago
lzshlzsh 9ce36569fb
[cdc-connector][postgres] Fix data lost problem when new lsn committed to slot between snapshotState and notifyCheckpointComplete (#2539)
This closes #2538.
Co-authored-by: sammieliu <sammieliu@tencent.com>
1 year ago
Hongshun Wang e3d6c7e0aa
[cdc-connector][postgres] Apply DBZ-5398 postgres connector to handle functional unique index (#2842)
This closes #2710.
1 year ago
Kunni 9abf2cf900
[hotfix][cdc-connector][mysql] Skip SchemaChangeEvents that were not included in capturedTableFilter (#2986)
This closes #2981
1 year ago
Hongshun Wang e3f6829263 [cdc-connector][mongodb] Add SNAPSHOT_ONLY mode for Mongodb CDC Source 1 year ago
Hongshun Wang 0e4f835f6d [cdc-connector][Postgres] Add SNAPSHOT_ONLY mode for Postgres CDC Source 1 year ago
Hongshun Wang 1cbdb4f8ae [cdc-connector][cdc-base] Add SNAPSHOT_ONLY mode for Incremental CDC Source framework (#2901) 1 year ago
Hongshun Wang 3bf886b94d [cdc-connector][mysql] Add SNAPSHOT_ONLY mode for Mysql CDC Source (#2901) 1 year ago
Hongshun Wang 35d3c0ff28
[cdc-base][hotfix] Fix SourceSplitSerializer to get totalFinishedSplitSize from recovery in 4th version
This closes #2992.
1 year ago
gongzhongqiang a24c5d1b24
[cdc][e2e] Unify logic to clean docker image when connector e2e test finished (#2978) 1 year ago
He Wang f3762a1b30
[pipeline-connector][mysql] fix timestamp with timezone format (#2952)
* fix ts with tz parser

* test timestamp with default value

* fix related test

* use timestamp string in test cases
1 year ago