Xin Gong
|
e2ccc836a0
|
[FLINK-34908][pipeline-connector][doris] Fix MySQL to doris pipeline will lose precision for timestamp type
This closes #3207.
|
8 months ago |
yuxiqian
|
1a360635c7
|
[FLINK-35092][cdc][starrocks] Add starrocks integration test cases
|
8 months ago |
|
yuxiqian
|
8eb7e53965
|
[FLINK-35120][doris] Add Doris integration test cases
|
8 months ago |
joyCurry30
|
8a7fdd5ae3
|
[minor][cdc-connector][paimon] Remove duplicate interface implements
|
8 months ago |
|
joyCurry30
|
0214166049
|
[FLINK-35325][cdc-connector][paimon] Support specify column order when adding new columns to a table
This closes #3323.
|
8 months ago |
Muhammet Orazov
|
5b28d1a579
|
[FLINK-35129][postgres] Introduce scan.lsn-commit.checkpoints-num-delay option to control LSN offset commit lazily
This close #3349.
|
8 months ago |
|
joyCurry30
|
0e8b2c7cc5
|
[FLINK-35430][cdc-connector][kafka] Pass the time zone infor to JsonSerializationSchema
This closes #3359.
|
8 months ago |
Shawn Huang
|
19c382c0f2
|
[FLINK-35409][cdc][mysql] Request more splits if all splits are filtered from addSplits method
This closes #3342.
|
8 months ago |
|
Shawn Huang
|
b2cb30f240
|
[FLINK-35408][mysql] Introduce 30 minutes tolerance when validate the time-zone setting
This closes #3341.
|
9 months ago |
|
Shawn Huang
|
6350eec66c
|
[FLINK-35301][cdc] Avoid deadlock when loading driver classes
This closes #3300.
|
9 months ago |
|
Shawn Huang
|
18b0627e34
|
[FLINK-35295][mysql] Improve jdbc connection pool initialization failure message
This closes #3293.
|
9 months ago |
|
Shawn Huang
|
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 |
|
Shawn Huang
|
8e8fd304af
|
[FLINK-35298][cdc][metrics] Improve the fetch delay metrics
This closes #3298.
|
9 months ago |
Xie Yi
|
fa6e7ea512
|
[FLINK-35245][cdc-connector][tidb] Add metrics for flink-connector-tidb-cdc
|
9 months ago |
|
Xin Gong
|
a7cb46f762
|
[FLINK-35274][cdc-connector][db2] Fix occasional failure issue with Flink CDC Db2 UT
|
9 months ago |
|
Xie Yi
|
002b16ed4e
|
[FLINK-35244][cdc-connector][tidb] Correct the package for flink-connector-tidb-cdc test
|
9 months ago |
Kunni
|
ec643c9dd7
|
[FLINK-35235][pipeline-connector][kafka] Fix missing dependencies in the uber jar of Kafka pipeline sink
|
10 months ago |
ConradJam
|
6232d84052
|
[FLINK-35173][cdc][mysql] Debezium custom time serializer for MySQL connector (#3240)
|
10 months ago |
He Wang
|
05281e5d6f
|
[FLINK-34639][cdc][oceanbase] Support debezium deserializer in OceanBase source connector (#3124)
|
10 months ago |
Hongshun Wang
|
bdca0e328b
|
[FLINK-35128][cdc-connector][cdc-base] Re-calculate the starting changelog offset after the new table added (#3230)
|
10 months ago |
Leonard Xu
|
ddf557c8e1
|
[tests][cdc-connector][db2] Improve the DB2 tests
This closes #2870
|
10 months ago |
|
Leonard Xu
|
8deddab6eb
|
[minor][cdc-connector][db2] Fix typos and improve the code style
|
10 months ago |
|
gong
|
3385ae8fbc
|
[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 |