Skip to content

Commit 775efbf

Browse files
authored
chore: Fix array_intersect test (#2246)
* chore: Fix `array_interest` test * chore: Fix `array_interest` test
1 parent ae35db7 commit 775efbf

File tree

1 file changed

+2
-6
lines changed

1 file changed

+2
-6
lines changed

spark/src/test/scala/org/apache/comet/CometArrayExpressionSuite.scala

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -429,11 +429,7 @@ class CometArrayExpressionSuite extends CometTestBase with AdaptiveSparkPlanHelp
429429
}
430430

431431
test("array_intersect") {
432-
// TODO test fails if scan is auto
433-
// https://github.com/apache/datafusion-comet/issues/2174
434-
withSQLConf(
435-
CometConf.COMET_NATIVE_SCAN_IMPL.key -> CometConf.SCAN_NATIVE_COMET,
436-
CometConf.COMET_EXPR_ALLOW_INCOMPATIBLE.key -> "true") {
432+
withSQLConf(CometConf.COMET_EXPR_ALLOW_INCOMPATIBLE.key -> "true") {
437433

438434
Seq(true, false).foreach { dictionaryEnabled =>
439435
withTempDir { dir =>
@@ -443,7 +439,7 @@ class CometArrayExpressionSuite extends CometTestBase with AdaptiveSparkPlanHelp
443439
checkSparkAnswerAndOperator(
444440
sql("SELECT array_intersect(array(_2, _3, _4), array(_3, _4)) from t1"))
445441
checkSparkAnswerAndOperator(
446-
sql("SELECT array_intersect(array(_2 * -1), array(_9, _10)) from t1"))
442+
sql("SELECT array_intersect(array(_4 * -1), array(_5)) from t1"))
447443
checkSparkAnswerAndOperator(
448444
sql("SELECT array_intersect(array(_18), array(_19)) from t1"))
449445
}

0 commit comments

Comments
 (0)