fix

apache · Nov 6, 2023 · c61c658 · c61c658
1 parent c0dfb2f
commit c61c658
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 5 deletions.
diff --git a/gluten-core/src/main/scala/io/glutenproject/execution/HashAggregateExecBaseTransformer.scala b/gluten-core/src/main/scala/io/glutenproject/execution/HashAggregateExecBaseTransformer.scala
@@ -442,8 +442,12 @@ abstract class HashAggregateExecBaseTransformer(
       aggFunc: AggregateFunction,
       mode: AggregateMode): Boolean = {
     aggFunc match {
-      case _: CollectList | _: CollectSet | bloom
-          if bloom.getClass.getSimpleName.equals("BloomFilterAggregate") =>
+      case _: CollectList | _: CollectSet =>
+        mode match {
+          case Partial | Final => true
+          case _ => false
+        }
+      case bloom if bloom.getClass.getSimpleName.equals("BloomFilterAggregate") =>
         mode match {
           case Partial | Final => true
           case _ => false

diff --git a/gluten-core/src/main/scala/io/glutenproject/extension/ExpressionExtensionTrait.scala b/gluten-core/src/main/scala/io/glutenproject/extension/ExpressionExtensionTrait.scala
@@ -20,9 +20,6 @@ import io.glutenproject.expression.{ExpressionTransformer, Sig}
 
 import org.apache.spark.internal.Logging
 import org.apache.spark.sql.catalyst.expressions.{Attribute, Expression}
-import org.apache.spark.sql.catalyst.expressions.aggregate.{AggregateExpression, AggregateFunction, AggregateMode}
-
-import scala.collection.mutable.ListBuffer
 
 trait ExpressionExtensionTrait {
 

diff --git a/gluten-core/src/main/scala/io/glutenproject/utils/ReflectUtil.scala b/gluten-core/src/main/scala/io/glutenproject/utils/ReflectUtil.scala
@@ -0,0 +1,3 @@
+package io.glutenproject.utils class ReflectUtil {
+
+}
Original file line number	Diff line number	Diff line change
		@@ -0,0 +1,3 @@
		package io.glutenproject.utils class ReflectUtil {

		}