Skip to content

Commit

Permalink
[Spark] Fix the inaccurate issue of obtaining COLUMN_SIZE in the deci…
Browse files Browse the repository at this point in the history
…mal field jdbc of spark engine
  • Loading branch information
waywtdcc committed Nov 27, 2023
1 parent 4286354 commit 2d288f5
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -140,7 +140,7 @@ object SchemaHelper {
case dt
if Array(TIMESTAMP_NTZ, DAY_TIME_INTERVAL, YEAR_MONTH_INTERVAL)
.contains(dt.getClass.getSimpleName) => Some(dt.defaultSize)
case dt @ (_: DecimalType) =>
case dt: DecimalType =>
Some(dt.precision)
case dt @ (BooleanType | _: NumericType | DateType | TimestampType |
CalendarIntervalType | NullType) =>
Expand Down

0 comments on commit 2d288f5

Please sign in to comment.