diff --git ql/src/java/org/apache/hadoop/hive/ql/io/parquet/vector/VectorizedParquetRecordReader.java ql/src/java/org/apache/hadoop/hive/ql/io/parquet/vector/VectorizedParquetRecordReader.java index fd776cf978..cc5bba2f4c 100644 --- ql/src/java/org/apache/hadoop/hive/ql/io/parquet/vector/VectorizedParquetRecordReader.java +++ ql/src/java/org/apache/hadoop/hive/ql/io/parquet/vector/VectorizedParquetRecordReader.java @@ -478,8 +478,16 @@ private PrimitiveType getElementType(Type type) { throw new RuntimeException( "Current Parquet Vectorization reader doesn't support nested type"); } - return type.asGroupType().getFields().get(0).asGroupType().getFields().get(0) - .asPrimitiveType(); + + Type childType = type.asGroupType().getFields().get(0); + + // Parquet file generated using thrift may have child type as PrimitiveType + if (childType.isPrimitive()) { + return childType.asPrimitiveType(); + } else { + return childType.asGroupType().getFields().get(0) + .asPrimitiveType(); + } } // Build VectorizedParquetColumnReader via Hive typeInfo and Parquet schema