[hotfix][cdc-base] Fix OffsetFactory is not initialized when restored from checkpoint ()

pull/1662/head
Jiabao Sun committed by GitHub
parent 5b3dd9884e
commit fbf5eba03c
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

@ -51,7 +51,7 @@ public class HybridSplitAssigner implements SplitAssigner {
private final SnapshotSplitAssigner snapshotSplitAssigner;
private OffsetFactory offsetFactory;
private final OffsetFactory offsetFactory;
public HybridSplitAssigner(
SourceConfig sourceConfig,
@ -69,8 +69,8 @@ public class HybridSplitAssigner implements SplitAssigner {
dialect,
offsetFactory),
false,
sourceConfig.getSplitMetaGroupSize());
this.offsetFactory = offsetFactory;
sourceConfig.getSplitMetaGroupSize(),
offsetFactory);
}
public HybridSplitAssigner(
@ -87,16 +87,19 @@ public class HybridSplitAssigner implements SplitAssigner {
dialect,
offsetFactory),
checkpoint.isStreamSplitAssigned(),
sourceConfig.getSplitMetaGroupSize());
sourceConfig.getSplitMetaGroupSize(),
offsetFactory);
}
private HybridSplitAssigner(
SnapshotSplitAssigner snapshotSplitAssigner,
boolean isStreamSplitAssigned,
int splitMetaGroupSize) {
int splitMetaGroupSize,
OffsetFactory offsetFactory) {
this.snapshotSplitAssigner = snapshotSplitAssigner;
this.isStreamSplitAssigned = isStreamSplitAssigned;
this.splitMetaGroupSize = splitMetaGroupSize;
this.offsetFactory = offsetFactory;
}
@Override

Loading…
Cancel
Save