@@ -44,7 +44,6 @@ import org.apache.spark.sql.types._
44
44
import org .apache .comet .CometSparkSessionExtensions .isSpark40Plus
45
45
46
46
class CometExpressionSuite extends CometTestBase with AdaptiveSparkPlanHelper {
47
-
48
47
import testImplicits ._
49
48
50
49
override protected def test (testName : String , testTags : Tag * )(testFun : => Any )(implicit
@@ -368,15 +367,15 @@ class CometExpressionSuite extends CometTestBase with AdaptiveSparkPlanHelper {
368
367
withParquetTable(data, " tbl" ) {
369
368
checkSparkAnswerAndOperator(" SELECT try_divide(_1, _2) FROM tbl" )
370
369
checkSparkAnswerAndOperator("""
371
- |SELECT
372
- | try_divide(10, 0),
373
- | try_divide(NULL, 5),
374
- | try_divide(5, NULL),
375
- | try_divide(-2147483648, -1),
376
- | try_divide(-9223372036854775808, -1),
377
- | try_divide(DECIMAL('9999999999999999999999999999'), 0.1)
378
- | from tbl
379
- |""" .stripMargin)
370
+ |SELECT
371
+ | try_divide(10, 0),
372
+ | try_divide(NULL, 5),
373
+ | try_divide(5, NULL),
374
+ | try_divide(-2147483648, -1),
375
+ | try_divide(-9223372036854775808, -1),
376
+ | try_divide(DECIMAL('9999999999999999999999999999'), 0.1)
377
+ | from tbl
378
+ |""" .stripMargin)
380
379
}
381
380
}
382
381
@@ -385,13 +384,13 @@ class CometExpressionSuite extends CometTestBase with AdaptiveSparkPlanHelper {
385
384
withParquetTable(data, " tbl" ) {
386
385
checkSparkAnswerAndOperator(" SELECT try_divide(_1, _2) FROM tbl" )
387
386
checkSparkAnswerAndOperator("""
388
- |SELECT try_divide(-128, -1),
389
- |try_divide(-32768, -1),
390
- |try_divide(-2147483648, -1),
391
- |try_divide(-9223372036854775808, -1),
392
- |try_divide(CAST(99999 AS DECIMAL(5,0)), CAST(0.0001 AS DECIMAL(5,4)))
393
- |from tbl
394
- |""" .stripMargin)
387
+ |SELECT try_divide(-128, -1),
388
+ |try_divide(-32768, -1),
389
+ |try_divide(-2147483648, -1),
390
+ |try_divide(-9223372036854775808, -1),
391
+ |try_divide(CAST(99999 AS DECIMAL(5,0)), CAST(0.0001 AS DECIMAL(5,4)))
392
+ |from tbl
393
+ |""" .stripMargin)
395
394
}
396
395
}
397
396
@@ -400,15 +399,10 @@ class CometExpressionSuite extends CometTestBase with AdaptiveSparkPlanHelper {
400
399
val data = Seq ((100 , 0 ))
401
400
withParquetTable(data, " t1" ) {
402
401
val res = spark.sql("""
403
- |SELECT coalesce(_1 , 1/0) from t1;
404
- | """ .stripMargin)
405
-
406
- res.explain(true )
407
-
402
+ |SELECT coalesce(_1 , 1/0) from t1;
403
+ | """ .stripMargin)
408
404
checkSparkAnswer(res)
409
405
}
410
- }
411
- }
412
406
413
407
test(" dictionary arithmetic" ) {
414
408
// TODO: test ANSI mode
0 commit comments