Skip to content

Commit 3d7772e

Browse files
committed
remove sum for testing purpose
1 parent ddb672f commit 3d7772e

File tree

2 files changed

+2
-8
lines changed

2 files changed

+2
-8
lines changed

spark/src/main/scala/org/apache/comet/serde/QueryPlanSerde.scala

+1-1
Original file line numberDiff line numberDiff line change
@@ -209,7 +209,7 @@ object QueryPlanSerde extends Logging with ShimQueryPlanSerde with CometExprShim
209209
expr match {
210210
case agg: AggregateExpression =>
211211
agg.aggregateFunction match {
212-
case _: Min | _: Max | _: Count | _: Sum =>
212+
case _: Min | _: Max | _: Count =>
213213
Some(agg)
214214
case _ =>
215215
withInfo(windowExpr, "Unsupported aggregate", expr)

spark/src/test/scala/org/apache/comet/exec/CometExecSuite.scala

+1-7
Original file line numberDiff line numberDiff line change
@@ -1510,13 +1510,7 @@ class CometExecSuite extends CometTestBase {
15101510
SQLConf.ADAPTIVE_EXECUTION_ENABLED.key -> aqeEnabled) {
15111511
withParquetTable((0 until 10).map(i => (i, 10 - i)), "t1") { // TODO: test nulls
15121512
val aggregateFunctions =
1513-
List(
1514-
"COUNT(_1)",
1515-
"COUNT(*)",
1516-
"MAX(_1)",
1517-
"MIN(_1)",
1518-
"SUM(_1)"
1519-
) // TODO: Test all the aggregates
1513+
List("COUNT(_1)", "COUNT(*)", "MAX(_1)", "MIN(_1)") // TODO: Test all the aggregates
15201514

15211515
aggregateFunctions.foreach { function =>
15221516
val queries = Seq(

0 commit comments

Comments
 (0)