fix

apache · Jul 30, 2024 · a1ef7ce · a1ef7ce
1 parent f060a4b
commit a1ef7ce
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/FullStartingScanner.java b/paimon-core/src/main/java/org/apache/paimon/table/source/snapshot/FullStartingScanner.java
@@ -42,6 +42,10 @@ public ScanMode startingScanMode() {
 
     @Override
     public Result scan(SnapshotReader snapshotReader) {
+        if (startingSnapshotId == null) {
+            // try to get first snapshot again
+            startingSnapshotId = snapshotManager.latestSnapshotId();
+        }
         if (startingSnapshotId == null) {
             LOG.debug("There is currently no snapshot. Waiting for snapshot generation.");
             return new NoSnapshot();