[hotfix][cdc-base] Fix OffsetFactory is not initialized when restored…

… from checkpoint (#1657)
apache · Oct 27, 2022 · fbf5eba · fbf5eba
1 parent 5b3dd98
commit fbf5eba
Showing 1 changed file with 8 additions and 5 deletions.
diff --git a/.../src/main/java/com/ververica/cdc/connectors/base/source/assigner/HybridSplitAssigner.java b/.../src/main/java/com/ververica/cdc/connectors/base/source/assigner/HybridSplitAssigner.java
@@ -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 HybridSplitAssigner(
                         dialect,
                         offsetFactory),
                 false,
-                sourceConfig.getSplitMetaGroupSize());
-        this.offsetFactory = offsetFactory;
+                sourceConfig.getSplitMetaGroupSize(),
+                offsetFactory);
     }
 
     public HybridSplitAssigner(
@@ -87,16 +87,19 @@ public HybridSplitAssigner(
                         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