flink-cdc
flink-cdc copied to clipboard
apache
Flink CDC is a streaming data integration tool
**Describe the bug(Please use English)** A clear and concise description of what the bug is. **Environment :** - Flink version : 1.14.4 - Flink CDC version: 2.2.1 - Database and...
FlinkCDC Job has been cancelled，but the connection bwteen JobManager and mysql is still ESTABLISHED
FlinkCDC Job has been cancelled，but the connection bwteen JobManager and mysql is still ESTABLISHED. **Environment :** - Flink version : 1.13.6 - Flink CDC version: 2.2.0 - Database and version:...
We only catch Exception in ChunkSplitter, the Error can not catch in ChunkSplitter. If user meet driver conflicts issue, the Error will be thrown but we can not catch it...
**Describe the bug(Please use English)** A clear and concise description of what the bug is. **Environment :** - Flink version : 1.13 - Flink CDC version: 2.1 - Database and...
**Describe the bug(Please use English)** A clear and concise description of what the bug is. **Environment :** - Flink version : 1.14 - Flink CDC version: 2.2.1 - Database and...
**Describe the bug(Please use English)** We are trying to use Flink Tidb CDC to synchronize data from tidb to tidb, since we have data encryption issues we chose to use...
### feature 1. startup mode support of timestamp and earliest 2. support of gtid mode ### demo in java ```java MySqlSource mySqlSource = MySqlSource.builder() .hostname("172.23.218.236") .port(3308) .databaseList("db_test") // set captured...
The first draft of MongoDB parallel source.
**Environment :** - Flink version : 1.13.5 - Flink CDC version: 2.2.0 - Database and version: mysql 5.7.28-log When I added a new table (about 1.5 million data) to an...
