fix

yuzelin · Nov 20, 2024 · 6d88d78 · 6d88d78
1 parent 400bdd6
commit 6d88d78
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/paimon-core/src/main/java/org/apache/paimon/table/source/DataTableStreamScan.java b/paimon-core/src/main/java/org/apache/paimon/table/source/DataTableStreamScan.java
@@ -201,9 +201,7 @@ private Plan nextPlan() {
                     nextSnapshotId++;
                     return overwritePlan;
                 }
-            }
-
-            if (followUpScanner.shouldScanSnapshot(snapshot)) {
+            } else if (followUpScanner.shouldScanSnapshot(snapshot)) {
                 LOG.debug("Find snapshot id {}.", nextSnapshotId);
                 SnapshotReader.Plan plan = followUpScanner.scan(snapshot, snapshotReader);
                 currentWatermark = plan.watermark();