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 8645d51..0acadfd 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 @@ -393,7 +393,7 @@ public static MessageType getRequestedSchema( return DataWritableReadSupport .getSchemaByIndex(tableSchema, columnNamesList, indexColumnsWanted); } else { - return fileSchema; + return tableSchema; } }