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)