Fix fallback

apache · Dec 5, 2023 · 2aa05a0 · 2aa05a0
1 parent 9d17812
commit 2aa05a0
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/gluten-core/src/main/scala/io/glutenproject/backendsapi/SparkPlanExecApi.scala b/gluten-core/src/main/scala/io/glutenproject/backendsapi/SparkPlanExecApi.scala
@@ -423,7 +423,8 @@ trait SparkPlanExecApi {
                   attributeSeq = originalInputAttributes)
                 .doTransform(args))
             // Spark only accepts foldable offset. Converts it to LongType literal.
-            val offsetExpression = Literal.create(offsetWf.offset.eval(EmptyRow), LongType)
+            val offsetExpression =
+              Literal.create(offsetWf.offset.eval(EmptyRow).asInstanceOf[Int].toLong, LongType)
             childrenNodeList.add(
               ExpressionConverter
                 .replaceWithExpressionTransformer(