(fluss) branch main updated: [hotfix] Fix flink batch read won't finish issue (#2200)

[yuxia]

This is an automated email from the ASF dual-hosted git repository.

yuxia pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/fluss.git


The following commit(s) were added to refs/heads/main by this push:
     new 356004cbe [hotfix] Fix flink batch read won't finish issue (#2200)
356004cbe is described below

commit 356004cbe0bf80f5d634c39475311a9ce2fa759d
Author: yuxia Luo <luoyu...@alumni.sjtu.edu.cn>
AuthorDate: Thu Dec 18 15:08:39 2025 +0800

    [hotfix] Fix flink batch read won't finish issue (#2200)
---
 .../org/apache/fluss/flink/source/enumerator/FlinkSourceEnumerator.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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
index a569fb144..55a9c871c 100644
--- 
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 @@ public class FlinkSourceEnumerator
                         t);
             }
         }
-        doHandleSplitsAdd(splits);
         if (isPartitioned) {
             if (!streaming || scanPartitionDiscoveryIntervalMs <= 0) {
                 // if not streaming or partition discovery is disabled
@@ -700,6 +699,7 @@ public class FlinkSourceEnumerator
             // so, noMoreNewPartitionSplits should be set to true
             noMoreNewSplits = true;
         }
+        doHandleSplitsAdd(splits);
     }
 
     private void doHandleSplitsAdd(List<SourceSplitBase> splits) {