Skip to content

Commit 1068f75

Browse files
committed
sum_ansi_mode_checks_fix_tests
1 parent 91503c3 commit 1068f75

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
@@ -3093,7 +3093,7 @@ class CometExpressionSuite extends CometTestBase with AdaptiveSparkPlanHelper {
30933093
"tbl") {
30943094
val res = sql("SELECT _2, sum(_1) FROM tbl group by 1")
30953095
checkSparkAnswerAndOperator(res)
3096-
assert(res.collect() === Array(Row("a", null), Row("b", null)))
3096+
assert(res.orderBy(col("_2")).collect() === Array(Row("a", null), Row("b", null)))
30973097
}
30983098
}
30993099
}
@@ -3112,7 +3112,7 @@ class CometExpressionSuite extends CometTestBase with AdaptiveSparkPlanHelper {
31123112
"tbl") {
31133113
val res = sql("SELECT _2, sum(_1) FROM tbl group by 1")
31143114
checkSparkAnswerAndOperator(res)
3115-
assert(res.collect() === Array(Row("a", null), Row("b", null)))
3115+
assert(res.orderBy(col("_2")).collect() === Array(Row("a", null), Row("b", null)))
31163116
}
31173117
}
31183118
}

0 commit comments

Comments
 (0)