Hongshun Wang created FLINK-35128:
-------------------------------------
Summary: Re-calculate the starting binlog offset after the new
table added
Key: FLINK-35128
URL: https://issues.apache.org/jira/browse/FLINK-35128
Project: Flink
Issue Type: Improvement
Components: Flink CDC
Reporter: Hongshun Wang
Fix For: 3.1.0
In mysql cdc, re-calculate the starting binlog offset after the new table added
in MySqlBinlogSplit#appendFinishedSplitInfos, while there lack of same action
in StreamSplit#appendFinishedSplitInfos. This will cause data loss if any newly
added table snapshot split's highwatermark is smaller.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
