Skip to content

Commit 57ac275

Browse files
committed
chore: Fallback to Spark for array_reverse for binary
1 parent 44272c7 commit 57ac275

File tree

1 file changed

+6
-5
lines changed

1 file changed

+6
-5
lines changed

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

Lines changed: 6 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -776,11 +776,12 @@ class CometArrayExpressionSuite extends CometTestBase with AdaptiveSparkPlanHelp
776776

777777
// https://github.com/apache/datafusion-comet/issues/2612
778778
test("array_reverse - fallback for binary array") {
779-
val fallbackReason = if (CometConf.COMET_NATIVE_SCAN_IMPL.key == "native_scan") {
780-
"Unsupported schema"
781-
} else {
782-
CometArrayReverse.unsupportedReason
783-
}
779+
val fallbackReason =
780+
if (CometConf.COMET_NATIVE_SCAN_IMPL.key == CometConf.SCAN_NATIVE_COMET) {
781+
"Unsupported schema"
782+
} else {
783+
CometArrayReverse.unsupportedReason
784+
}
784785
withTable("t1") {
785786
sql("""create table t1 using parquet as
786787
select cast(null as array<binary>) c1, cast(array() as array<binary>) c2

0 commit comments

Comments
 (0)