File tree 1 file changed +10
-6
lines changed
spark/src/test/scala/org/apache/spark/sql/comet
1 file changed +10
-6
lines changed Original file line number Diff line number Diff line change @@ -325,9 +325,11 @@ class CometTPCDSV1_4_PlanStabilitySuite extends CometPlanStabilitySuite {
325
325
override val goldenFilePath : String =
326
326
new File (baseResourcePath, planName).getAbsolutePath
327
327
328
- tpcdsQueries.foreach { q =>
329
- test(s " check simplified (tpcds-v1.4/ $q) " ) {
330
- testQuery(" tpcds" , q)
328
+ if (CometConf .COMET_NATIVE_SCAN_IMPL .get().equals(CometConf .SCAN_NATIVE_COMET )) {
329
+ tpcdsQueries.foreach { q =>
330
+ test(s " check simplified (tpcds-v1.4/ $q) " ) {
331
+ testQuery(" tpcds" , q)
332
+ }
331
333
}
332
334
}
333
335
}
@@ -343,9 +345,11 @@ class CometTPCDSV2_7_PlanStabilitySuite extends CometPlanStabilitySuite {
343
345
override val goldenFilePath : String =
344
346
new File (baseResourcePath, planName).getAbsolutePath
345
347
346
- tpcdsQueriesV2_7_0.foreach { q =>
347
- test(s " check simplified (tpcds-v2.7.0/ $q) " ) {
348
- testQuery(" tpcds-v2.7.0" , q)
348
+ if (CometConf .COMET_NATIVE_SCAN_IMPL .get().equals(CometConf .SCAN_NATIVE_COMET )) {
349
+ tpcdsQueriesV2_7_0.foreach { q =>
350
+ test(s " check simplified (tpcds-v2.7.0/ $q) " ) {
351
+ testQuery(" tpcds-v2.7.0" , q)
352
+ }
349
353
}
350
354
}
351
355
}
You can’t perform that action at this time.
0 commit comments