diff --git a/pom.xml b/pom.xml index d2a5d52..0383e01 100644 --- a/pom.xml +++ b/pom.xml @@ -154,7 +154,7 @@ 1.9.5 2.0.0-M5 4.0.23.Final - 1.7.0 + 1.8.1 0.12.0 2.5.0 1.0.1 diff --git a/ql/src/java/org/apache/hadoop/hive/ql/io/parquet/read/DataWritableReadSupport.java b/ql/src/java/org/apache/hadoop/hive/ql/io/parquet/read/DataWritableReadSupport.java index 8b8b92d..97f228f 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/io/parquet/read/DataWritableReadSupport.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/io/parquet/read/DataWritableReadSupport.java @@ -225,9 +225,13 @@ private static MessageType getSchemaByIndex(MessageType schema, List col contextMetadata.put(HIVE_TABLE_AS_PARQUET_SCHEMA, tableSchema.toString()); List indexColumnsWanted = ColumnProjectionUtils.getReadColumnIDs(configuration); - MessageType requestedSchemaByUser = getSchemaByIndex(tableSchema, columnNamesList, indexColumnsWanted); - - return new ReadContext(requestedSchemaByUser, contextMetadata); + if (!ColumnProjectionUtils.isReadAllColumns(configuration) && !indexColumnsWanted.isEmpty()) { + MessageType requestedSchemaByUser = + getSchemaByIndex(tableSchema, columnNamesList, indexColumnsWanted); + return new ReadContext(requestedSchemaByUser, contextMetadata); + } else { + return new ReadContext(tableSchema, contextMetadata); + } } else { contextMetadata.put(HIVE_TABLE_AS_PARQUET_SCHEMA, fileSchema.toString()); return new ReadContext(fileSchema, contextMetadata);