Skip to content

Commit 40478e3

Browse files
committed
fix: provide fallback reason for ArrayFilter operator
CometArrayFilter.getSupportLevel returned Unsupported() with no reason for unsupported filter functions, resulting in empty fallback messages. Add an explicit reason string.
1 parent c3f59a6 commit 40478e3

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

spark/src/main/scala/org/apache/comet/serde/arrays.scala

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -622,7 +622,8 @@ object CometArrayFilter extends CometExpressionSerde[ArrayFilter] {
622622
override def getSupportLevel(expr: ArrayFilter): SupportLevel = {
623623
expr.function.children.headOption match {
624624
case Some(_: IsNotNull) => Compatible()
625-
case _ => Unsupported()
625+
case _ =>
626+
Unsupported(Some("Only array_compact (ArrayFilter with IsNotNull) is supported"))
626627
}
627628
}
628629

0 commit comments

Comments
 (0)