[
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()
for (MySqlSchemalessSnapshotSplit split : assignedSnapshotSplit) {
BinlogOffset binlogOffset = splitFinishedOffsets.get(split.splitId());
new FinishedSnapshotSplitInfo(
split.getTableId(),
split.splitId(), // for the same keys
split.getSplitStart(),
split.getSplitEnd(),
binlogOffset));
}
// imporve
for (MySqlSchemalessSnapshotSplit split : assignedSnapshotSplit) {
String splitId = split.splitId(); // 缓存一次
BinlogOffset binlogOffset = splitFinishedOffsets.get(splitId);
finishedSnapshotSplitInfos.add(
new FinishedSnapshotSplitInfo(
split.getTableId(),
splitId,
split.getSplitStart(),
split.getSplitEnd(),
binlogOffset));
}{code}
was:
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}
> 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()
> for (MySqlSchemalessSnapshotSplit split : assignedSnapshotSplit) {
> BinlogOffset binlogOffset = splitFinishedOffsets.get(split.splitId());
> new FinishedSnapshotSplitInfo(
> split.getTableId(),
> split.splitId(), // for the same keys
> split.getSplitStart(),
> split.getSplitEnd(),
> binlogOffset));
>
> }
> // imporve
> for (MySqlSchemalessSnapshotSplit split : assignedSnapshotSplit) {
> String splitId = split.splitId(); // 缓存一次
> BinlogOffset binlogOffset = splitFinishedOffsets.get(splitId);
> finishedSnapshotSplitInfos.add(
> new FinishedSnapshotSplitInfo(
> split.getTableId(),
> splitId,
> split.getSplitStart(),
> split.getSplitEnd(),
> binlogOffset));
> }{code}
>
>
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
