diff --git a/jdbc-handler/src/main/java/org/apache/hive/storage/jdbc/JdbcSerDe.java b/jdbc-handler/src/main/java/org/apache/hive/storage/jdbc/JdbcSerDe.java index add1a1919b..d4f65d9069 100644 --- a/jdbc-handler/src/main/java/org/apache/hive/storage/jdbc/JdbcSerDe.java +++ b/jdbc-handler/src/main/java/org/apache/hive/storage/jdbc/JdbcSerDe.java @@ -203,7 +203,7 @@ public Object deserialize(Writable blob) throws SerDeException { if (rowVal instanceof Number) { rowVal = ((Number) value).intValue() != 0; } else { - rowVal = Boolean.valueOf(value.toString()); + rowVal = Boolean.valueOf(rowVal.toString()); } break; case CHAR: @@ -224,12 +224,7 @@ public Object deserialize(Writable blob) throws SerDeException { } break; case TIMESTAMP: - if (rowVal instanceof java.sql.Timestamp) { - java.sql.Timestamp timestampRowVal = (java.sql.Timestamp) rowVal; - rowVal = Timestamp.ofEpochMilli(timestampRowVal.getTime(), timestampRowVal.getNanos()); - } else { - rowVal = Timestamp.valueOf (rowVal.toString()); - } + rowVal = Timestamp.valueOf (rowVal.toString()); break; default: //do nothing