diff --git a/ql/src/java/org/apache/hadoop/hive/ql/io/parquet/convert/ETypeConverter.java b/ql/src/java/org/apache/hadoop/hive/ql/io/parquet/convert/ETypeConverter.java index 3fc0129..71c0333 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/io/parquet/convert/ETypeConverter.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/io/parquet/convert/ETypeConverter.java @@ -178,9 +178,8 @@ private ETypeConverter(final Class type) { public static PrimitiveConverter getNewConverter(final PrimitiveType type, final int index, final ConverterParent parent) { - if (type.isPrimitive() && (type.asPrimitiveType().getPrimitiveTypeName().equals(PrimitiveType.PrimitiveTypeName.INT96))) { - //TODO- cleanup once parquet support Timestamp type annotation. - return ETypeConverter.ETIMESTAMP_CONVERTER.getConverter(type, index, parent); + if (type.isPrimitive()) { + return ETIMESTAMP_CONVERTER.getConverter(type, index, parent); } if (OriginalType.DECIMAL == type.getOriginalType()) { return EDECIMAL_CONVERTER.getConverter(type, index, parent);