flink-cdc

flink-cdc copied to clipboard

[FLINK-35757][mysql] support dynamically capture new tables

1

currently if we set tableList with regex like db.*, after snapshot finished, we can't capture tables when create new tables in db. instead, we need to restart to snapshot new...

Karl-WangSK

Refactored Identifiers

1

Changed names of several identifiers, including variables and constants, to be more grammatically coherent to the use case of the identifiers.

congyuluo

[FLINK-35888][cdc-connector][paimon] Add e2e test for PaimonDataSink.

3

Add e2e test for PaimonDataSink.

lvyanquan

optimize the update operation in binlog events

6

Fixes #40： Add optional flag `capture-unchanged-updates` whether to capture the updates if that have no change or not. default true, false to disable, just simply equals the before and after...

shizhengchao

[WIP] tidb netty worker leak

2

GOODBOY008

[mysql] Use cursor fetch by default when snapshot.

5

[mysql] Use cursor fetch by default when snapshot.

GOODBOY008

[tidb-cdc]fix too many fields cause the value to be NULL

7

fix issues：https://github.com/ververica/flink-cdc-connectors/issues/1883

MengXiangDing

[oracle][fix]fix oracle maximum number of processes exceeded

4

[oracle][fix]fix oracle maximum number of processes exceeded because of never close connection during snapshot

Cheers0606

[FLINK-36517][cdc-connect][paimon] use filterAndCommit API for Avoid commit the same datafile duplicate

4

https://issues.apache.org/jira/browse/FLINK-35938 problem still persists. `storeMultiCommitter.commit` API may cause the same datafile commit twice when job restart from failure.

beryllw

Flink CDC has been released and we're preparing for the following 3.3 release. Adding it to migration testing matrix should help us ensuring state backwards compatibility.

yuxiqian