[hotfix] Fix flink batch read won't finish issue (#2200)

luoyuxia · web-flow · commit 356004cbe0bf · 2025-12-18T15:08:39.000+08:00
diff --git a/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/source/enumerator/FlinkSourceEnumerator.java b/fluss-flink/fluss-flink-common/src/main/java/org/apache/fluss/flink/source/enumerator/FlinkSourceEnumerator.java
@@ -688,7 +688,6 @@ private void handleSplitsAdd(List<SourceSplitBase> splits, Throwable t) {
                         t);
             }
         }
-        doHandleSplitsAdd(splits);
         if (isPartitioned) {
             if (!streaming || scanPartitionDiscoveryIntervalMs <= 0) {
                 // if not streaming or partition discovery is disabled
@@ -700,6 +699,7 @@ private void handleSplitsAdd(List<SourceSplitBase> splits, Throwable t) {
             // so, noMoreNewPartitionSplits should be set to true
             noMoreNewSplits = true;
         }
+        doHandleSplitsAdd(splits);
     }
 
     private void doHandleSplitsAdd(List<SourceSplitBase> splits) {

Original file line number	Diff line number	Diff line change
`@@ -688,7 +688,6 @@ private void handleSplitsAdd(List<SourceSplitBase> splits, Throwable t) {`
`688`	`688`	`t);`
`689`	`689`	`}`
`690`	`690`	`}`
`691`		`- doHandleSplitsAdd(splits);`
`692`	`691`	`if (isPartitioned) {`
`693`	`692`	`if (!streaming \|\| scanPartitionDiscoveryIntervalMs <= 0) {`
`694`	`693`	`// if not streaming or partition discovery is disabled`
`@@ -700,6 +699,7 @@ private void handleSplitsAdd(List<SourceSplitBase> splits, Throwable t) {`
`700`	`699`	`// so, noMoreNewPartitionSplits should be set to true`
`701`	`700`	`noMoreNewSplits = true;`
`702`	`701`	`}`
	`702`	`+ doHandleSplitsAdd(splits);`
`703`	`703`	`}`
`704`	`704`
`705`	`705`	`private void doHandleSplitsAdd(List<SourceSplitBase> splits) {`