update

apache · Dec 19, 2024 · 29fefb5 · 29fefb5
1 parent dbaff4a
commit 29fefb5
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/...c/main/scala/org/apache/paimon/spark/catalyst/analysis/expressions/ExpressionHelper.scala b/...c/main/scala/org/apache/paimon/spark/catalyst/analysis/expressions/ExpressionHelper.scala
@@ -180,12 +180,11 @@ trait ExpressionHelper extends PredicateHelper {
           }
           filter
       })
-      .toArray
 
-    if (filters.isEmpty) {
+    val predicates = filters.map(converter.convert(_, ignorePartialFailure)).filter(_ != null)
+    if (predicates.isEmpty) {
       None
     } else {
-      val predicates = filters.map(converter.convert(_, ignorePartialFailure))
       Some(PredicateBuilder.and(predicates: _*))
     }
   }