Skip to content

Commit

Permalink
Fix PR issues
Browse files Browse the repository at this point in the history
  • Loading branch information
Kazantsev Maksim committed Jan 30, 2025
1 parent ffc8e08 commit 1cd459d
Showing 1 changed file with 1 addition and 10 deletions.
11 changes: 1 addition & 10 deletions spark/src/main/scala/org/apache/comet/serde/QueryPlanSerde.scala
Original file line number Diff line number Diff line change
Expand Up @@ -2367,16 +2367,7 @@ object QueryPlanSerde extends Logging with ShimQueryPlanSerde with CometExprShim
case _: ArrayJoin => convert(CometArrayJoin)
case _: ArraysOverlap => convert(CometArraysOverlap)
case expr @ ArrayFilter(child, _) if ArrayCompact(child).replacement.sql == expr.sql =>
if (CometConf.COMET_CAST_ALLOW_INCOMPATIBLE.get()) {
convert(CometArrayCompact)
} else {
withInfo(
expr,
s"array_compact is not fully compatible with Spark. " +
s"Set ${CometConf.COMET_CAST_ALLOW_INCOMPATIBLE.key}=true " +
"to allow it anyway.")
None
}
convert(CometArrayCompact)
case _ =>
withInfo(expr, s"${expr.prettyName} is not supported", expr.children: _*)
None
Expand Down

0 comments on commit 1cd459d

Please sign in to comment.