Skip to content

Commit

Permalink
[cdc-base][hotfix] Fix SourceSplitSerializer to get totalFinishedSpli…
Browse files Browse the repository at this point in the history
…tSize from recovery in 4th version

This closes #2992.

(cherry picked from commit 35d3c0f)
  • Loading branch information
loserwang1024 authored and lvyanquan committed Jan 18, 2024
1 parent f4c3e31 commit 92e1910
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -159,7 +159,7 @@ public SourceSplitBase deserializeSplit(int version, byte[] serialized) throws I
readFinishedSplitsInfo(version, in);
Map<TableId, TableChange> tableChangeMap = readTableSchemas(version, in);
int totalFinishedSplitSize = finishedSplitsInfo.size();
if (version == 3) {
if (version >= 3) {
totalFinishedSplitSize = in.readInt();
}
in.releaseArrays();
Expand Down

0 comments on commit 92e1910

Please sign in to comment.