File tree Expand file tree Collapse file tree 1 file changed +0
-20
lines changed
spark/src/test/scala/org/apache/comet/exec Expand file tree Collapse file tree 1 file changed +0
-20
lines changed Original file line number Diff line number Diff line change @@ -1914,26 +1914,6 @@ class CometAggregateSuite extends CometTestBase with AdaptiveSparkPlanHelper {
19141914 }
19151915 }
19161916
1917- test(
1918- " SPARK-39190,SPARK-39208,SPARK-39210: Query context of decimal overflow error should " +
1919- " be serialized to executors when WSCG is off" ) {
1920- withSQLConf(
1921- SQLConf .WHOLESTAGE_CODEGEN_ENABLED .key -> " false" ,
1922- SQLConf .ANSI_ENABLED .key -> " true" ) {
1923- withTable(" t" ) {
1924- sql(" create table t(d decimal(38, 0)) using parquet" )
1925- sql(" insert into t values (6e37BD),(6e37BD)" )
1926- Seq (" select d / 0.1 from t" , " select sum(d) from t" , " select avg(d) from t" ).foreach {
1927- query =>
1928- val msg = intercept[ArithmeticException ] {
1929- sql(query).collect()
1930- }.getMessage
1931- assert(msg.contains(query))
1932- }
1933- }
1934- }
1935- }
1936-
19371917 protected def checkSparkAnswerAndNumOfAggregates (query : String , numAggregates : Int ): Unit = {
19381918 val df = sql(query)
19391919 checkSparkAnswer(df)
You can’t perform that action at this time.
0 commit comments