flink-cdc
flink-cdc copied to clipboard
Flink CDC is a streaming data integration tool
make ObjectUtils can not be instantiated
This PR fixed #2075
#2034 I fix that bug.
The PR removes usage of deprecated `TableSchema.fromResolvedSchema`
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.