[
https://issues.apache.org/jira/browse/FLINK-39168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thorne updated FLINK-39168:
---------------------------
Description:
A little improvement when get(split.splitId()) 。
{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}
was:
{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}
> 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
> Priority: Minor
>
> A little improvement when get(split.splitId()) 。
> {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)
