flink-cdc icon indicating copy to clipboard operation
flink-cdc copied to clipboard

Flink CDC is a streaming data integration tool

Results 606 flink-cdc issues
Sort by recently updated
recently updated
newest added

The PR removes usage of deprecated `TableSchema.fromResolvedSchema`

db2-cdc-connector

MySqlSplitSerializer iterate over tableSchemas may cause java.util.ConcurrentModificationException.

Fix oracle scn huge increment, logminer streaming change event can't catch up the latest records

Fix bug: #1886 In the snapshot, `record.key()` is null, so it will overwrite the previous record. So we can to add record without primary key into list. ```java if (!reachChangeLogStart)...

Because callback( [eventListeners](https://github.com/shyiko/mysql-binlog-connector-java/blob/dd710a5466381faa57442977b24fceff56a0820e/src/main/java/com/github/shyiko/mysql/binlog/BinaryLogClient.java#L142) and lifecycleListeners) of BinaryLogClient is a list, and BinaryLogClient may reuse (see [MySqlSplitReader#checkSplitOrStartNext](https://github.com/ververica/flink-cdc-connectors/blob/eb5610c29bf6deee9abc1f5a28208f0a0b02b99a/flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/source/reader/MySqlSplitReader.java#L139)),when multiple snapshotSplits are submitted to a [SnapshotSplitReader](https://github.com/ververica/flink-cdc-connectors/blob/eb5610c29bf6deee9abc1f5a28208f0a0b02b99a/flink-connector-mysql-cdc/src/main/java/com/ververica/cdc/connectors/mysql/source/reader/MySqlSplitReader.java#L159), the callback list contains already processed snapshotSplits's...

fixed: https://github.com/ververica/flink-cdc-connectors/issues/1893

Use debezium SPI way to improve common data types output by JsonDebeziumDeserializationSchema.