diff --git a/kyuubi-hive-jdbc/src/main/java/org/apache/kyuubi/jdbc/hive/JdbcColumn.java b/kyuubi-hive-jdbc/src/main/java/org/apache/kyuubi/jdbc/hive/JdbcColumn.java index a0fb967a51b..51be8fbe3a3 100644 --- a/kyuubi-hive-jdbc/src/main/java/org/apache/kyuubi/jdbc/hive/JdbcColumn.java +++ b/kyuubi-hive-jdbc/src/main/java/org/apache/kyuubi/jdbc/hive/JdbcColumn.java @@ -19,7 +19,7 @@ import static java.sql.Types.*; -import java.math.BigInteger; +import java.math.BigDecimal; import java.sql.Date; import java.sql.SQLException; import java.sql.Timestamp; @@ -126,7 +126,7 @@ static String columnClassName(TTypeId tType, JdbcColumnAttributes columnAttribut case TIMESTAMP_WITH_TIMEZONE: return TimestampTZ.class.getName(); case DECIMAL: - return BigInteger.class.getName(); + return BigDecimal.class.getName(); case BINARY: return byte[].class.getName(); case OTHER: