flink-cdc

flink-cdc copied to clipboard

[tidb-cdc] data loss when switch from snapshot read to change event read

5

**Describe the bug(Please use English)** data loss when switch from snapshot read to change event read **Environment :** - Flink version : flink 1.14 - Flink CDC version: 2.2.0 -...

xieyi888

Flink CDC Orcale Source Whether can support automatic scanning new table functions, like mysql CDC scanNewlyAddedTableEnabled feature function.

Rowen110

Mongo CDC setting checkpoint does not take effect.

2

**Describe the bug(Please use English)** Mongo setting checkpoint does not take effect. **Environment :** - Flink version : 1.13.3 - Flink CDC version: 2.3-SNAPSHOT(mongo) - Database and version: 4.0.9 **To...

421119407

Failed to deserialize data of EventHeaderV4

11

**Describe the bug** When multiple Flink CDCs synchronize the same MySQL database instance at the same time, this error is most likely to occur if the database is updated with...

q2515045

about the last one MySqlSnapshotSplit

1

**Describe the bug(Please use English)** A clear and concise description of what the bug is. **Environment :** - Flink version : 1.13.5 - Flink CDC version: 2.2.1 - Database and...

jiangjin-f

## Good For Newcomers * [x] #356 * [ ] #345 * [x] #346 * [x] #370 * [x] #381 * [x] #343 * [x] #249 * [x] #162 *...

leonardBang

**Describe the bug(Please use English)** use flink-cdc mysql to mysql . insert matadata op_ts (read from snapshot) error ： Data truncation: Incorrect datetime value: '1970-01-01 00:00:00.0' for column 'operation_ts' at...

rcf666

**Describe the bug(Please use English)** In using MacBook of m1 chip to run UT, the docker image could not pull. **Environment :** - Flink version : - Flink CDC version:...

minchowang

Oracle CDC 2.2.0 报错 Caused by: java.sql.SQLException: ORA-01289: cannot add duplicate logfile +DATA/jxr2p/onlinelog/group_4.294.1016480325

6

Describe the bug(Please use English) A clear and concise description of what the bug is. Environment : Flink version : 1.13.3 Flink CDC version: 2.2.0 Database and version: Oracle 11g...

szhengshuai

Support dynamically table addition in flink-cdc-base

1

Currently `flink-cdc-base` framework doesn't support discovering and adding tables dynamically. This feature is already implemented in MySQL CDC connector so it's required to support it in the framework in order...

PatrickRen