From 4bc277ad996a97d09acc505aa28e51902a1e78c2 Mon Sep 17 00:00:00 2001 From: zouxxyy Date: Mon, 3 Jun 2024 18:27:06 +0800 Subject: [PATCH] for failed test --- .../spark/catalyst/analysis/expressions/ExpressionHelper.scala | 1 + 1 file changed, 1 insertion(+) 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 e801867670ef..333508125dbc 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 @@ -128,6 +128,7 @@ trait ExpressionHelper extends PredicateHelper { partitionColumns: Seq[String], resolver: Resolver ): Boolean = { + condition.references.nonEmpty && condition.references.forall(r => partitionColumns.exists(resolver(r.name, _))) }