remove duplicated columns in agg results (#7937)

apache · Nov 14, 2024 · 59d5248 · 59d5248
1 parent 0b899c0
commit 59d5248
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/backends-clickhouse/src/main/scala/org/apache/gluten/extension/LazyAggregateExpandRule.scala b/backends-clickhouse/src/main/scala/org/apache/gluten/extension/LazyAggregateExpandRule.scala
@@ -353,7 +353,7 @@ case class LazyAggregateExpandRule(session: SparkSession) extends Rule[SparkPlan
         s"resultExpressions:${partialAggregate.resultExpressions}")
     partialAggregate.copy(
       groupingExpressions = groupingExpressions,
-      resultExpressions = resultExpressions,
+      resultExpressions = resultExpressions.distinct,
       child = expand.child)
   }