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 index 47f360a599e8..bfeb79953592 100644 --- 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) }