Skip to content

Commit 50bbb21

Browse files
committed
sum_ansi_mode_checks_fix_tests
1 parent 2ff9dbd commit 50bbb21

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

native/spark-expr/src/agg_funcs/sum_int.rs

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -17,8 +17,8 @@
1717

1818
use crate::{arithmetic_overflow_error, EvalMode};
1919
use arrow::array::{
20-
cast::AsArray, Array, ArrayRef, ArrowNativeTypeOp, ArrowPrimitiveType,
21-
BooleanArray, Int64Array, PrimitiveArray,
20+
cast::AsArray, Array, ArrayRef, ArrowNativeTypeOp, ArrowPrimitiveType, BooleanArray,
21+
Int64Array, PrimitiveArray,
2222
};
2323
use arrow::datatypes::{
2424
ArrowNativeType, DataType, Field, FieldRef, Int16Type, Int32Type, Int64Type, Int8Type,

spark/src/test/scala/org/apache/comet/CometExpressionSuite.scala

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -3043,7 +3043,7 @@ class CometExpressionSuite extends CometTestBase with AdaptiveSparkPlanHelper {
30433043
"tbl") {
30443044
val res = sql("SELECT _2, sum(_1) FROM tbl group by 1")
30453045
checkSparkAnswerAndOperator(res)
3046-
assert(res.collect() === Array(Row("a", null), Row("b", null)))
3046+
assert(res.orderBy(col("_2")).collect() === Array(Row("a", null), Row("b", null)))
30473047
}
30483048
}
30493049
}
@@ -3062,7 +3062,7 @@ class CometExpressionSuite extends CometTestBase with AdaptiveSparkPlanHelper {
30623062
"tbl") {
30633063
val res = sql("SELECT _2, sum(_1) FROM tbl group by 1")
30643064
checkSparkAnswerAndOperator(res)
3065-
assert(res.collect() === Array(Row("a", null), Row("b", null)))
3065+
assert(res.orderBy(col("_2")).collect() === Array(Row("a", null), Row("b", null)))
30663066
}
30673067
}
30683068
}

0 commit comments

Comments
 (0)