[cdc-base] Fix StreamSplit's endingOffset of StreamSplitAssigner (#1659)

2 years ago · 21521506c0
parent ddd0680009
commit 21521506c0
1 changed files with 1 additions and 1 deletions
--- a/flink-cdc-base/src/main/java/com/ververica/cdc/connectors/base/source/assigner/StreamSplitAssigner.java
+++ b/flink-cdc-base/src/main/java/com/ververica/cdc/connectors/base/source/assigner/StreamSplitAssigner.java
@ -127,7 +127,7 @@ public class StreamSplitAssigner implements SplitAssigner {
        return new StreamSplit(
                BINLOG_SPLIT_ID,
                dialect.displayCurrentOffset(sourceConfig),
-                offsetFactory.createInitialOffset(),
+                offsetFactory.createNoStoppingOffset(),
                new ArrayList<>(),
                new HashMap<>(),
                0);