Skip to content

Commit a2b7590

Browse files
committed
fallback reverse with array input
1 parent e2b16ce commit a2b7590

1 file changed

Lines changed: 2 additions & 2 deletions

File tree

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1044,7 +1044,7 @@ class CometCastSuite extends CometTestBase with AdaptiveSparkPlanHelper {
10441044
conf.getConfString(CometConf.COMET_NATIVE_SCAN_IMPL.key, "native_comet"))
10451045
val cometScanTypeChecker = CometScanTypeChecker(scanImpl)
10461046
val hasIncompatibleType =
1047-
(dt: DataType) => cometScanTypeChecker.isTypeSupported(dt, scanImpl, ListBuffer.empty)
1047+
(dt: DataType) => !cometScanTypeChecker.isTypeSupported(dt, scanImpl, ListBuffer.empty)
10481048
Seq(
10491049
BooleanType,
10501050
StringType,
@@ -1058,7 +1058,7 @@ class CometCastSuite extends CometTestBase with AdaptiveSparkPlanHelper {
10581058
DecimalType(38, 18),
10591059
BinaryType).foreach { dt =>
10601060
val input = generateArrays(100, dt)
1061-
castTest(input, StringType, !hasIncompatibleType(input.schema))
1061+
castTest(input, StringType, hasIncompatibleType(input.schema))
10621062
}
10631063
}
10641064

0 commit comments

Comments
 (0)