ConradJam
|
f476a5b1dd
|
[FLINK-35592][cdc] Fix MysqlDebeziumTimeConverter miss timezone convert to timestamp (#3380)
|
8 months ago |
North Lin
|
7287eaceca
|
[FLINK-35540][cdc-common] Fix table missed when database and table are with the same name
This closes #3409.
|
8 months ago |
Xin Gong
|
1112987572
|
[FLINK-34908][pipeline-connector][doris] Fix MySQL to doris pipeline will lose precision for timestamp type
This closes #3407.
|
8 months ago |
yuxiqian
|
a18cacec34
|
[FLINK-35092][cdc][starrocks] Add starrocks integration test cases
|
8 months ago |
|
yuxiqian
|
a74fb376d7
|
[FLINK-35120][doris] Add Doris integration test cases
|
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 |
joyCurry30
|
19f7afe6af
|
[FLINK-35430][cdc-connector][kafka] Pass the time zone info to JsonSerializationSchema
This closes #3377.
|
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
|
f522308206
|
[hotfix] Change parent POM's artifact ID to flink-cdc-parent
|
10 months ago |
|
Qingsheng Ren
|
38a1782ecc
|
[hotfix] Remove test-jar from parent pom and only add to necessary modules
|
10 months ago |
Kunni
|
b96ea11cc7
|
[FLINK-35235][pipeline-connector][kafka] Fix missing dependencies in the uber jar of Kafka pipeline sink
|
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 |
|
Kunni
|
ef2eece256
|
[pipeline-connector][paimon] add paimon pipeline data sink connector. (#2916)
|
10 months ago |
|
yux
|
01ec7da989
|
[FLINK-35055][cdc] Exclude connector dependencies with questionable licenses from fat jar packages (#3212)
|
10 months ago |
|
Kunni
|
253ef9256b
|
[pipeline-connector][kafka] Add kafka pipeline data sink connector. (#2938)
|
10 months ago |
|
yux
|
5e52d8620c
|
[FLINK-35102][cdc][doris-sink] Correct Doris connector varchar type mapping
This closes #3224.
|
10 months ago |
Thorne
|
0d797a6021
|
[FLINK-34903][cdc][mysql] Add mysql-pipeline-connector with tables.exclude option to exclude unnecessary tables (#3186)
|
10 months ago |
|
Kunni
|
d4ed7db8dc
|
[FLINK-35127][cdc][values] Remove HybridSource from ValuesSource to avoid CI failure. (#3237)
|
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 |
|
Hongshun Wang
|
025653d772
|
[hotfix] run mvn spotless to fix code style violations. (#3219)
|
10 months ago |
Qishang Zhong
|
18dd51fe22
|
[FLINK-34905][cdc-connector][mysql] Fix the default length of CHAR/BINARY data type of Add column DDL (#3145)
|
10 months ago |
|
Hongshun Wang
|
abb98ee257
|
[FLINK-34690] Cast decimal to VARCHAR as primary key in starrocks sink (#3150)
|
10 months ago |
shikai93
|
80d461b1b8
|
[MySQL] Fix for DBZ-7037 and #2217 to not clear tableMapEventByTableId for fake Rotates Event (#3065)
|
10 months ago |
|
Hongshun Wang
|
8c5437a1f1
|
[FLINK-34952][cdc-composer][sink] Flink CDC pipeline supports SinkFunction (#3204)
|
10 months ago |
xleoken
|
6510e670fa
|
[FLINK-34959][cdc] Update old flink-cdc-connectors artifactId (#3200)
|
10 months ago |
wenmo
|
a35b8dd44c
|
[build] Optimize pom to solve the CI error
|
10 months ago |
|
wenmo
|
bcad5d9d11
|
[cdc-runtime] Introduce TransformSchemaOperator and TransformDataOperator to support transformation
|
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 |