From a1ef7ced407b1f3f763f98e25511b1fcbd7e3270 Mon Sep 17 00:00:00 2001 From: Jingsong Date: Tue, 30 Jul 2024 17:16:38 +0800 Subject: [PATCH] fix --- .../paimon/table/source/snapshot/FullStartingScanner.java | 4 ++++ 1 file changed, 4 insertions(+) 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 index eeb076f1fc50a..fc9b49d2d60a1 100644 --- 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();