diff --git a/paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/catalyst/analysis/expressions/ExpressionHelper.scala b/paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/catalyst/analysis/expressions/ExpressionHelper.scala index 45b2d1feefe4..480546201ccb 100644 --- a/paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/catalyst/analysis/expressions/ExpressionHelper.scala +++ b/paimon-spark/paimon-spark-common/src/main/scala/org/apache/paimon/spark/catalyst/analysis/expressions/ExpressionHelper.scala @@ -185,7 +185,7 @@ trait ExpressionHelper extends PredicateHelper { if (filters.isEmpty) { None } else { - val predicates = filters.map(converter.convert(_, ignorePartialFailure)).filter(_ != null) + val predicates = filters.map(converter.convert(_, ignorePartialFailure)) Some(PredicateBuilder.and(predicates: _*)) } }