diff --git a/core/src/main/java/org/apache/iceberg/MicroBatches.java b/core/src/main/java/org/apache/iceberg/MicroBatches.java index d97dc7fd811c..798c3379b1fd 100644 --- a/core/src/main/java/org/apache/iceberg/MicroBatches.java +++ b/core/src/main/java/org/apache/iceberg/MicroBatches.java @@ -242,7 +242,7 @@ private CloseableIterable open(ManifestFile manifestFile, boolean ManifestGroup manifestGroup = new ManifestGroup(io, ImmutableList.of(manifestFile)) .specsById(specsById) .caseSensitive(caseSensitive); - if (scanAllFiles) { + if (!scanAllFiles) { manifestGroup = manifestGroup .filterManifestEntries(entry -> entry.snapshotId() == snapshot.snapshotId() && entry.status() == ManifestEntry.Status.ADDED)