Thorne created FLINK-39168:
------------------------------
Summary: improve mysql’s snapshot-split
Key: FLINK-39168
URL: https://issues.apache.org/jira/browse/FLINK-39168
Project: Flink
Issue Type: Improvement
Components: Flink CDC
Affects Versions: cdc-3.5.0
Reporter: Thorne
{code:java}
// split.splitId()
BinlogOffset binlogOffset = splitFinishedOffsets.get(split.splitId());
new FinishedSnapshotSplitInfo(
split.getTableId(),
split.splitId(), // for the same keys
split.getSplitStart(),
split.getSplitEnd(),
binlogOffset));
{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
