comment

apache · May 29, 2024 · 3995aec · 3995aec
1 parent d378106
commit 3995aec
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/...on-flink-common/src/main/java/org/apache/paimon/flink/lookup/FileStoreLookupFunction.java b/...on-flink-common/src/main/java/org/apache/paimon/flink/lookup/FileStoreLookupFunction.java
@@ -258,9 +258,8 @@ private Predicate createSpecificPartFilter(BinaryRow partition) {
         List<Predicate> predicates = new ArrayList<>();
         for (int i = 0; i < partitionKeys.size(); i++) {
             int index = fieldNames.indexOf(partitionKeys.get(i));
-            predicates.add(
-                    builder.equal(
-                            index, InternalRowUtils.get(partition, i, rowType.getTypeAt(index))));
+            Object value = InternalRowUtils.get(partition, i, rowType.getTypeAt(index));
+            predicates.add(value == null ? builder.isNull(index) : builder.equal(index, value));
         }
         return PredicateBuilder.and(predicates);
     }