update plans

Author: comphead

spark/src/test/scala/org/apache/comet/exec/CometAggregateSuite.scala

@@ -680,7 +680,8 @@ class CometAggregateSuite extends CometTestBase with AdaptiveSparkPlanHelper {
   test("partialMerge - cnt distinct + sum") {
     withTempDir(dir => {
       withSQLConf("spark.comet.enabled" -> "false") {
-        sql("""
+        withView("t") {
+          sql("""
               CREATE OR REPLACE TEMP VIEW t (v, v1, i) AS
               VALUES
                 ('c',  'a',  1),
@@ -699,28 +700,22 @@ class CometAggregateSuite extends CometTestBase with AdaptiveSparkPlanHelper {
                 ('c3', 'a3', 2),
                 ('c4', 'a4', 2)
               """)
-        sql("select * from t")
-          .repartition(3)
-          .write
-          .mode("overwrite")
-          .parquet(dir.getAbsolutePath)
+          sql("select * from t")
+            .repartition(3)
+            .write
+            .mode("overwrite")
+            .parquet(dir.getAbsolutePath)
+        }
       }
 
       withSQLConf(
         CometConf.COMET_EXEC_SHUFFLE_ENABLED.key -> "true",
         "spark.comet.exec.shuffle.fallbackToColumnar" -> "false",
         "spark.comet.cast.allowIncompatible" -> "true",
         "spark.sql.adaptive.enabled" -> "false",
-        "spark.comet.explain.native.enabled" -> "true",
         "spark.comet.enabled" -> "true",
         "spark.comet.expression.Cast.allowIncompatible" -> "true",
-        "spark.comet.exec.shuffle.enableFastEncoding" -> "true",
-        "spark.comet.exec.shuffle.enabled" -> "true",
-        "spark.comet.explainFallback.enabled" -> "true",
-        CometConf.COMET_NATIVE_SCAN_IMPL.key -> "native_iceberg_compat",
-        "spark.shuffle.manager" ->
-          "org.apache.spark.sql.comet.execution.shuffle.CometShuffleManager",
-        "spark.comet.logFallbackReasons.enabled" -> "true") {
+        CometConf.COMET_NATIVE_SCAN_IMPL.key -> "native_iceberg_compat") {
         spark.read.parquet(dir.getAbsolutePath).createOrReplaceTempView("t2")
         checkSparkAnswerAndOperator("SELECT i, sum(v1), count(distinct v) FROM t2 group by i")
       }