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);