Fix ArrayIndexOutOfBoundsException when parsing Hive timestamp column

trinodb · Dec 2, 2014 · 86a21b2 · 86a21b2
1 parent d8f7441
commit 86a21b2
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/presto-hive/src/main/java/com/facebook/presto/hive/ColumnarBinaryHiveRecordCursor.java b/presto-hive/src/main/java/com/facebook/presto/hive/ColumnarBinaryHiveRecordCursor.java
@@ -399,7 +399,7 @@ else if (hiveTypes[column].equals(HIVE_DATE)) {
         else if (hiveTypes[column].equals(HIVE_TIMESTAMP)) {
             checkState(length >= 1, "Timestamp should be at least 1 byte");
             long seconds = TimestampWritable.getSeconds(bytes, start);
-            long nanos = TimestampWritable.getNanos(bytes, start + SIZE_OF_INT);
+            long nanos = (bytes[start] >> 7) != 0 ? TimestampWritable.getNanos(bytes, start + SIZE_OF_INT) : 0;
             longs[column] = (seconds * 1000) + (nanos / 1_000_000);
         }
         else if (hiveTypes[column].equals(HIVE_BYTE)) {