From 21521506c0ec16506580249c554a9cd63af8a6e5 Mon Sep 17 00:00:00 2001
From: Jiabao Sun <jiabao.sun@xtransfer.cn>
Date: Thu, 27 Oct 2022 00:01:14 +0800
Subject: [PATCH] [cdc-base] Fix StreamSplit's endingOffset of
 StreamSplitAssigner (#1659)

---
 .../connectors/base/source/assigner/StreamSplitAssigner.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 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
index 33594f397..90e19194c 100644
--- 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);