Strip the partition columns domains from the effective predicate

trinodb · Dec 30, 2023 · b4f2803 · b4f2803
1 parent 89105bd
commit b4f2803
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/IcebergPageSourceProvider.java b/plugin/trino-iceberg/src/main/java/io/trino/plugin/iceberg/IcebergPageSourceProvider.java
@@ -429,7 +429,9 @@ private TupleDomain<IcebergColumnHandle> getEffectivePredicate(
         if (!partitionMatchesPredicate(partitionColumns, partitionValues, dynamicFilterPredicate)) {
             return TupleDomain.none();
         }
-
+        // Filter out partition columns domains from the dynamic filter because they should be irrelevant at data file level
+        dynamicFilterPredicate = dynamicFilterPredicate
+                .filter((columnHandle, domain) -> !partitionKeys.containsKey(columnHandle.getId()));
         return unenforcedPredicate.intersect(dynamicFilterPredicate);
     }