fix error

apache · Oct 11, 2024 · fd1b0a1 · fd1b0a1
1 parent 867285c
commit fd1b0a1
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/gluten-delta/src/main/scala/org/apache/gluten/extension/DeltaRewriteTransformerRules.scala b/gluten-delta/src/main/scala/org/apache/gluten/extension/DeltaRewriteTransformerRules.scala
@@ -60,7 +60,7 @@ object DeltaRewriteTransformerRules {
 
   val filterRule: Rule[SparkPlan] = (plan: SparkPlan) =>
     plan.transformUp {
-      case FilterExec(condition, child) if condition.exists(containsIncrementMetricExpr) =>
+      case FilterExec(condition, child) if containsIncrementMetricExpr(condition) =>
         DeltaFilterExecTransformer(condition, child)
     }