diff --git a/sql/api/src/main/scala/org/apache/spark/sql/util/ArrowUtils.scala b/sql/api/src/main/scala/org/apache/spark/sql/util/ArrowUtils.scala index d9bd3b0e612b..6852fe09ef96 100644 --- a/sql/api/src/main/scala/org/apache/spark/sql/util/ArrowUtils.scala +++ b/sql/api/src/main/scala/org/apache/spark/sql/util/ArrowUtils.scala @@ -51,7 +51,7 @@ private[sql] object ArrowUtils { case BinaryType if !largeVarTypes => ArrowType.Binary.INSTANCE case _: StringType if largeVarTypes => ArrowType.LargeUtf8.INSTANCE case BinaryType if largeVarTypes => ArrowType.LargeBinary.INSTANCE - case DecimalType.Fixed(precision, scale) => new ArrowType.Decimal(precision, scale) + case DecimalType.Fixed(precision, scale) => new ArrowType.Decimal(precision, scale, 8 * 16) case DateType => new ArrowType.Date(DateUnit.DAY) case TimestampType if timeZoneId == null => throw SparkException.internalError("Missing timezoneId where it is mandatory.")