diff --git a/ql/src/java/org/apache/hadoop/hive/ql/io/parquet/ProjectionPusher.java b/ql/src/java/org/apache/hadoop/hive/ql/io/parquet/ProjectionPusher.java index 42f9b66..855efa0 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/io/parquet/ProjectionPusher.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/io/parquet/ProjectionPusher.java @@ -115,7 +115,9 @@ private void pushProjectionsAndFilters(final JobConf jobConf, allColumnsNeeded = true; } else { neededColumnIDs.addAll(ts.getNeededColumnIDs()); - neededNestedColumnPaths.addAll(ts.getNeededNestedColumnPaths()); + if (ts.getNeededNestedColumnPaths() != null) { + neededNestedColumnPaths.addAll(ts.getNeededNestedColumnPaths()); + } } rowSchema = ts.getSchema();