update

apache · Nov 6, 2024 · c3e6bdb · c3e6bdb
1 parent 2facf71
commit c3e6bdb
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 1 deletion.
diff --git a/...ickhouse/src/main/scala/org/apache/gluten/backendsapi/clickhouse/CHSparkPlanExecApi.scala b/...ickhouse/src/main/scala/org/apache/gluten/backendsapi/clickhouse/CHSparkPlanExecApi.scala
@@ -194,7 +194,7 @@ class CHSparkPlanExecApi extends SparkPlanExecApi with Logging {
       aggregateAttributes,
       initialInputBufferOffset,
       // resultExpressions.distinct,
-      replacedResultExpressions,
+      replacedResultExpressions.distinct,
       child
     )
     agg

diff --git a/...lickhouse/src/main/scala/org/apache/gluten/execution/CHHashAggregateExecTransformer.scala b/...lickhouse/src/main/scala/org/apache/gluten/execution/CHHashAggregateExecTransformer.scala
@@ -56,6 +56,8 @@ object CHHashAggregateExecTransformer {
       aggExpr =>
         aggExpr.mode match {
           case Partial | PartialMerge =>
+            // For partial aggregate, the size of the result expressions of an aggregate expression
+            // is the same as aggBufferAttributes' length
             val aggBufferAttributesCount = aggExpr.aggregateFunction.aggBufferAttributes.length
             aggExpr.aggregateFunction match {
               case avg: Average =>