flink-cdc
flink-cdc copied to clipboard
[mysql-cdc] Current binlog offset add serverId, fix incremental-snapshot scan data lose
Current binlog offset add serverId, fix incremental-snapshot scan data lose link https://github.com/ververica/flink-cdc-connectors/issues/2794
The problem will occur when the gtid mode is closed and some data changes happen in the snapshot phase.
The problem will occur when the gtid mode is closed and some data changes happen in the snapshot phase.
Sorry for being late, I have added unit tests, please review them for me, thank you!
Hi @EchoLee5, could you please rebase this PR with latest master
branch before it could be merged?
cc @ruanhang1993
This pull request has been automatically marked as stale because it has not had recent activity for 60 days. It will be closed in 30 days if no further activity occurs.