fix decimal avg final agg output (apache#12)

rui-mo · Mar 22, 2023 · f839722 · f839722
1 parent 52a1bf0
commit f839722
Showing 1 changed file with 1 addition and 7 deletions.
diff --git a/...n-data/src/main/scala/io/glutenproject/execution/GlutenHashAggregateExecTransformer.scala b/...n-data/src/main/scala/io/glutenproject/execution/GlutenHashAggregateExecTransformer.scala
@@ -191,17 +191,11 @@ case class GlutenHashAggregateExecTransformer(
               getIntermediateTypeNode(aggregateFunction))
             aggregateNodeList.add(partialNode)
           case Final =>
-            val dataType = aggregateFunction match {
-              case avg: Average =>
-                GlutenDecimalUtil.getAvgSumDataType(avg)
-              case _ =>
-                aggregateFunction.dataType
-            }
             val aggFunctionNode = ExpressionBuilder.makeAggregateFunction(
               AggregateFunctionsBuilder.create(args, aggregateFunction),
               childrenNodeList,
               modeToKeyWord(aggregateMode),
-              ConverterUtils.getTypeNode(dataType, aggregateFunction.nullable))
+              ConverterUtils.getTypeNode(aggregateFunction.dataType, aggregateFunction.nullable))
             aggregateNodeList.add(aggFunctionNode)
           case other =>
             throw new UnsupportedOperationException(s"$other is not supported.")