Spark: Fix bucketed transform expression (#2138)

apache · Jan 22, 2021 · 524bf90 · 524bf90
1 parent c6b9698
commit 524bf90
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...sions/src/main/scala/org/apache/spark/sql/catalyst/expressions/TransformExpressions.scala b/...sions/src/main/scala/org/apache/spark/sql/catalyst/expressions/TransformExpressions.scala
@@ -99,7 +99,7 @@ case class IcebergBucketTransform(numBuckets: Int, child: Expression) extends Ic
   @transient lazy val bucketFunc: Any => Int = child.dataType match {
     case _: DecimalType =>
       val t = Transforms.bucket[Any](icebergInputType, numBuckets)
-      d: Any => t(d.asInstanceOf[Decimal].toBigDecimal).toInt
+      d: Any => t(d.asInstanceOf[Decimal].toJavaBigDecimal).toInt
     case _: StringType =>
       // the spec requires that the hash of a string is equal to the hash of its UTF-8 encoded bytes
       // TODO: pass bytes without the copy out of the InternalRow