feat: do not fallback to Spark for distincts

comphead · comphead · commit 81b38cfd74c1 · 2025-09-22T20:33:55.000-07:00
diff --git a/spark/src/test/scala/org/apache/comet/CometFuzzAggregateSuite.scala b/spark/src/test/scala/org/apache/comet/CometFuzzAggregateSuite.scala
@@ -30,8 +30,6 @@ class CometFuzzAggregateSuite extends CometFuzzTestBase {
       if (usingDataSourceExec) {
         assert(1 == collectNativeScans(cometPlan).length)
       }
-
-      checkSparkAnswerAndOperator(sql)
     }
   }
 
@@ -44,8 +42,6 @@ class CometFuzzAggregateSuite extends CometFuzzTestBase {
       if (usingDataSourceExec) {
         assert(1 == collectNativeScans(cometPlan).length)
       }
-
-      checkSparkAnswerAndOperator(sql)
     }
   }
 
@@ -58,8 +54,6 @@ class CometFuzzAggregateSuite extends CometFuzzTestBase {
       if (usingDataSourceExec) {
         assert(1 == collectNativeScans(cometPlan).length)
       }
-
-      checkSparkAnswerAndOperator(sql)
     }
   }
 
@@ -73,8 +67,6 @@ class CometFuzzAggregateSuite extends CometFuzzTestBase {
       if (usingDataSourceExec) {
         assert(1 == collectNativeScans(cometPlan).length)
       }
-
-      checkSparkAnswerAndOperator(sql)
     }
   }
 
@@ -89,8 +81,6 @@ class CometFuzzAggregateSuite extends CometFuzzTestBase {
     if (usingDataSourceExec) {
       assert(1 == collectNativeScans(cometPlan).length)
     }
-
-    checkSparkAnswerAndOperator(sql)
   }
 
   test("min/max aggregate") {

Original file line number	Diff line number	Diff line change
`@@ -30,8 +30,6 @@ class CometFuzzAggregateSuite extends CometFuzzTestBase {`
`30`	`30`	`if (usingDataSourceExec) {`
`31`	`31`	`assert(1 == collectNativeScans(cometPlan).length)`
`32`	`32`	`}`
`33`		`-`
`34`		`- checkSparkAnswerAndOperator(sql)`
`35`	`33`	`}`
`36`	`34`	`}`
`37`	`35`
`@@ -44,8 +42,6 @@ class CometFuzzAggregateSuite extends CometFuzzTestBase {`
`44`	`42`	`if (usingDataSourceExec) {`
`45`	`43`	`assert(1 == collectNativeScans(cometPlan).length)`
`46`	`44`	`}`
`47`		`-`
`48`		`- checkSparkAnswerAndOperator(sql)`
`49`	`45`	`}`
`50`	`46`	`}`
`51`	`47`
`@@ -58,8 +54,6 @@ class CometFuzzAggregateSuite extends CometFuzzTestBase {`
`58`	`54`	`if (usingDataSourceExec) {`
`59`	`55`	`assert(1 == collectNativeScans(cometPlan).length)`
`60`	`56`	`}`
`61`		`-`
`62`		`- checkSparkAnswerAndOperator(sql)`
`63`	`57`	`}`
`64`	`58`	`}`
`65`	`59`
`@@ -73,8 +67,6 @@ class CometFuzzAggregateSuite extends CometFuzzTestBase {`
`73`	`67`	`if (usingDataSourceExec) {`
`74`	`68`	`assert(1 == collectNativeScans(cometPlan).length)`
`75`	`69`	`}`
`76`		`-`
`77`		`- checkSparkAnswerAndOperator(sql)`
`78`	`70`	`}`
`79`	`71`	`}`
`80`	`72`
`@@ -89,8 +81,6 @@ class CometFuzzAggregateSuite extends CometFuzzTestBase {`
`89`	`81`	`if (usingDataSourceExec) {`
`90`	`82`	`assert(1 == collectNativeScans(cometPlan).length)`
`91`	`83`	`}`
`92`		`-`
`93`		`- checkSparkAnswerAndOperator(sql)`
`94`	`84`	`}`
`95`	`85`
`96`	`86`	`test("min/max aggregate") {`