diff --git ql/src/java/org/apache/hadoop/hive/ql/io/parquet/read/DataWritableReadSupport.java ql/src/java/org/apache/hadoop/hive/ql/io/parquet/read/DataWritableReadSupport.java index 30f3d1737d..3c84f88f57 100644 --- ql/src/java/org/apache/hadoop/hive/ql/io/parquet/read/DataWritableReadSupport.java +++ ql/src/java/org/apache/hadoop/hive/ql/io/parquet/read/DataWritableReadSupport.java @@ -444,7 +444,7 @@ private static MessageType getRequestedPrunedSchema( Configuration configuration) { Set groupPaths = ColumnProjectionUtils.getNestedColumnPaths(configuration); List indexColumnsWanted = ColumnProjectionUtils.getReadColumnIDs(configuration); - if (!ColumnProjectionUtils.isReadAllColumns(configuration) && !indexColumnsWanted.isEmpty()) { + if (!ColumnProjectionUtils.isReadAllColumns(configuration)) { return getProjectedSchema(fileSchema, columnNamesList, indexColumnsWanted, groupPaths); } else { return fileSchema;