update

apache · Sep 10, 2024 · fadae59 · fadae59
1 parent d3143f8
commit fadae59
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/...-connector/src/main/java/org/apache/doris/flink/source/reader/DorisSourceSplitReader.java b/...-connector/src/main/java/org/apache/doris/flink/source/reader/DorisSourceSplitReader.java
@@ -66,14 +66,15 @@ public RecordsWithSplitIds<List> fetch() throws IOException {
     }
 
     private void checkSplitOrStartNext() throws IOException, DorisException {
-        if (valueReader != null) {
+        if (valueReader != null && valueReader.hasNext()) {
             return;
         }
         final DorisSourceSplit nextSplit = splits.poll();
         if (nextSplit == null) {
             throw new IOException("Cannot fetch from another split - no split remaining");
         }
         currentSplitId = nextSplit.splitId();
+        LOG.info("currentSplitId {}, split {}", currentSplitId, nextSplit);
         valueReader =
                 ValueReader.createReader(
                         nextSplit.getPartitionDefinition(), options, readOptions, LOG);