fix pre-projection not take effect (#7863)

apache · Nov 8, 2024 · aac1b87 · aac1b87
1 parent cfb55ef
commit aac1b87
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...rc/main/scala/org/apache/gluten/extension/PushdownAggregatePreProjectionAheadExpand.scala b/...rc/main/scala/org/apache/gluten/extension/PushdownAggregatePreProjectionAheadExpand.scala
@@ -96,7 +96,7 @@ case class PushdownAggregatePreProjectionAheadExpand(session: SparkSession)
         def projectInputExists(expr: Expression, inputs: Seq[Attribute]): Boolean = {
           expr.children.foreach {
             case a: Attribute =>
-              return inputs.indexOf(a) != -1
+              return inputs.exists(i => i.name.equals(a.name) && i.exprId.equals(a.exprId))
             case p: Expression =>
               return projectInputExists(p, inputs)
             case _ =>