fix comment

apache · Jun 18, 2024 · ef5b4a4 · ef5b4a4
1 parent bb992b2
commit ef5b4a4
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/...imon-flink-common/src/main/java/org/apache/paimon/flink/procedure/FileIndexProcedure.java b/...imon-flink-common/src/main/java/org/apache/paimon/flink/procedure/FileIndexProcedure.java
@@ -18,6 +18,7 @@
 
 package org.apache.paimon.flink.procedure;
 
+import org.apache.paimon.CoreOptions;
 import org.apache.paimon.catalog.Identifier;
 import org.apache.paimon.flink.sink.FileIndexSink;
 import org.apache.paimon.flink.sink.NoneCopyVersionedSerializerTypeSerializerProxy;
@@ -76,7 +77,13 @@ public String[] call(
             partitionPredicate =
                     PredicateBuilder.or(
                             partitionList.stream()
-                                    .map(p -> PredicateBuilder.partition(p, table.rowType()))
+                                    .map(
+                                            p ->
+                                                    PredicateBuilder.partition(
+                                                            p,
+                                                            table.rowType(),
+                                                            CoreOptions.PARTITION_DEFAULT_NAME
+                                                                    .defaultValue()))
                                     .toArray(Predicate[]::new));
         } else {
             partitionPredicate = null;