diff --git a/spark/src/test/scala/org/apache/spark/sql/CometTestBase.scala b/spark/src/test/scala/org/apache/spark/sql/CometTestBase.scala index 90ca585630..8f3b3bce27 100644 --- a/spark/src/test/scala/org/apache/spark/sql/CometTestBase.scala +++ b/spark/src/test/scala/org/apache/spark/sql/CometTestBase.scala @@ -48,6 +48,7 @@ import org.apache.spark.sql.test._ import org.apache.spark.sql.types.{DecimalType, StructType} import org.apache.comet._ +import org.apache.comet.CometSparkSessionExtensions.isSpark40Plus import org.apache.comet.shims.ShimCometSparkSessionExtensions /** @@ -72,7 +73,7 @@ abstract class CometTestBase conf.set("spark.hadoop.fs.file.impl", classOf[DebugFilesystem].getName) conf.set("spark.ui.enabled", "false") conf.set(SQLConf.SHUFFLE_PARTITIONS, 10) // reduce parallelism in tests - conf.set(SQLConf.ANSI_ENABLED.key, "false") + conf.set(SQLConf.ANSI_ENABLED.key, isSpark40Plus.toString) conf.set(SHUFFLE_MANAGER, shuffleManager) conf.set(MEMORY_OFFHEAP_ENABLED.key, "true") conf.set(MEMORY_OFFHEAP_SIZE.key, "2g")