We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 8ca6bfa commit 3404bd0Copy full SHA for 3404bd0
1 file changed
paimon-python/pypaimon/read/scanner/incremental_starting_scanner.py
@@ -35,7 +35,7 @@ def plan_files(self) -> List[ManifestEntry]:
35
snapshots_in_range = []
36
for snapshot_id in range(self.startingSnapshotId + 1, self.endingSnapshotId + 1):
37
snapshot = self.snapshot_manager.get_snapshot_by_id(snapshot_id)
38
- if snapshot:
+ if snapshot.commit_kind == "APPEND":
39
snapshots_in_range.append(snapshot)
40
41
# Collect all file entries from all snapshots in range
0 commit comments