Skip to content

Commit c9e7e9b

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

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

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

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -777,7 +777,8 @@ class CometArrayExpressionSuite extends CometTestBase with AdaptiveSparkPlanHelp
777777
// https://github.com/apache/datafusion-comet/issues/2612
778778
test("array_reverse - fallback for binary array") {
779779
val fallbackReason =
780-
if (CometConf.COMET_NATIVE_SCAN_IMPL.key == CometConf.SCAN_NATIVE_COMET) {
780+
if (CometConf.COMET_NATIVE_SCAN_IMPL.key == CometConf.SCAN_NATIVE_COMET || sys.env
781+
.getOrElse("COMET_PARQUET_SCAN_IMPL", "") == CometConf.SCAN_NATIVE_COMET) {
781782
"Unsupported schema"
782783
} else {
783784
CometArrayReverse.unsupportedReason

0 commit comments

Comments
 (0)