[cdc-base][hotfix] Fix SourceSplitSerializer to get totalFinishedSplitSize from recovery in 4th version

This closes #2992.
pull/2842/head
Hongshun Wang 1 year ago committed by GitHub
parent 146ed9d0be
commit 35d3c0ff28
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

@ -159,7 +159,7 @@ public abstract class SourceSplitSerializer
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();

Loading…
Cancel
Save