fall back to Spark if range offset is not int or long

apache · Sep 18, 2024 · 63822c1 · 63822c1
1 parent 423bcc3
commit 63822c1
Showing 1 changed file with 2 additions and 6 deletions.
diff --git a/spark/src/main/scala/org/apache/comet/serde/QueryPlanSerde.scala b/spark/src/main/scala/org/apache/comet/serde/QueryPlanSerde.scala
@@ -283,9 +283,7 @@ object QueryPlanSerde extends Logging with ShimQueryPlanSerde with CometExprShim
             val offset = e.eval() match {
               case i: Integer => i.toLong
               case l: Long => l
-              case _ =>
-                throw new IllegalArgumentException(
-                  "Unsupported data type for window function row/range offset")
+              case _ => return None
             }
             OperatorOuterClass.LowerWindowFrameBound
               .newBuilder()
@@ -312,9 +310,7 @@ object QueryPlanSerde extends Logging with ShimQueryPlanSerde with CometExprShim
             val offset = e.eval() match {
               case i: Integer => i.toLong
               case l: Long => l
-              case _ =>
-                throw new IllegalArgumentException(
-                  "Unsupported data type for window function row/range offset")
+              case _ => return None
             }
 
             OperatorOuterClass.UpperWindowFrameBound