Flink CDC Issue Import created FLINK-34832: ----------------------------------------------
Summary: [Bug] BinlogOffset's comparative method may be cause incremental snapshot scan data lose Key: FLINK-34832 URL: https://issues.apache.org/jira/browse/FLINK-34832 Project: Flink Issue Type: Bug Components: Flink CDC Reporter: Flink CDC Issue Import ### Search before asking - [X] I searched in the [issues|https://github.com/ververica/flink-cdc-connectors/issues] and found nothing similar. ### Flink version 1.14.5 ### Flink CDC version 2.4.0 ### Database and its version MariaDB 10.4.13 ### Minimal reproduce step 1. create mysql test table 2. create a flink cdc sql task and set the startup mode to initial 3. while writing 10000 records to the test table, start the flink task and check the number of records sent by the data. ### What did you expect to see? The number of records is consistent with the mysql test table ### What did you see instead? data loss or duplication ### Anything else? _No response_ ### Are you willing to submit a PR? - [X] I'm willing to submit a PR! ![932A614C-53BF-4592-9E6C-D7F87BD6CD6F|https://github.com/ververica/flink-cdc-connectors/assets/39044001/742cd5a2-1312-47e6-9f6b-14e250198c36] ---------------- Imported from GitHub ---------------- Url: https://github.com/apache/flink-cdc/issues/2794 Created by: [EchoLee5|https://github.com/EchoLee5] Labels: bug, Created at: Fri Dec 01 19:28:48 CST 2023 State: open -- This message was sent by Atlassian Jira (v8.20.10#820010)