diff --git a/jdbc/src/java/org/apache/hive/jdbc/JdbcColumn.java b/jdbc/src/java/org/apache/hive/jdbc/JdbcColumn.java index d3b7098fa7fe..3970fa4afa34 100644 --- a/jdbc/src/java/org/apache/hive/jdbc/JdbcColumn.java +++ b/jdbc/src/java/org/apache/hive/jdbc/JdbcColumn.java @@ -18,7 +18,7 @@ package org.apache.hive.jdbc; -import java.math.BigInteger; +import java.math.BigDecimal; import java.sql.Date; import java.sql.SQLException; import java.sql.Timestamp; @@ -97,7 +97,7 @@ static String columnClassName(Type hiveType, JdbcColumnAttributes columnAttribut case Types.TIMESTAMP_WITH_TIMEZONE: return TimestampTZ.class.getName(); case Types.DECIMAL: - return BigInteger.class.getName(); + return BigDecimal.class.getName(); case Types.BINARY: return byte[].class.getName(); case Types.OTHER: