Skip to content

Commit 7bca529

Browse files
committed
update hasIncompatibleType
1 parent 56e5316 commit 7bca529

1 file changed

Lines changed: 6 additions & 1 deletion

File tree

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

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1047,6 +1047,11 @@ class CometCastSuite extends CometTestBase with AdaptiveSparkPlanHelper {
10471047
}
10481048

10491049
test("cast ArrayType to StringType") {
1050+
val scanImpl = sys.env
1051+
.getOrElse(
1052+
"COMET_PARQUET_SCAN_IMPL",
1053+
conf.getConfString(CometConf.COMET_NATIVE_SCAN_IMPL.key, "native_comet"))
1054+
val isNativeCometScan = scanImpl == "native_comet"
10501055
Seq(
10511056
BooleanType,
10521057
StringType,
@@ -1060,7 +1065,7 @@ class CometCastSuite extends CometTestBase with AdaptiveSparkPlanHelper {
10601065
DecimalType(38, 18),
10611066
BinaryType).foreach { dt =>
10621067
val input = generateArrays(100, dt)
1063-
castTest(input, StringType, hasIncompatibleType = usingParquetExecWithIncompatTypes)
1068+
castTest(input, StringType, hasIncompatibleType = isNativeCometScan)
10641069
}
10651070
}
10661071

0 commit comments

Comments
 (0)