diff --git ql/src/java/org/apache/hadoop/hive/ql/optimizer/ColumnPrunerProcFactory.java ql/src/java/org/apache/hadoop/hive/ql/optimizer/ColumnPrunerProcFactory.java index f49b7cd..111b048 100644 --- ql/src/java/org/apache/hadoop/hive/ql/optimizer/ColumnPrunerProcFactory.java +++ ql/src/java/org/apache/hadoop/hive/ql/optimizer/ColumnPrunerProcFactory.java @@ -491,6 +491,9 @@ public Object process(Node nd, Stack stack, NodeProcessorCtx ctx, for (ExprNodeDesc key : keys) { colLists = Utilities.mergeUniqElems(colLists, key.getCols()); } + for (ExprNodeDesc key : conf.getPartitionCols()) { + colLists = Utilities.mergeUniqElems(colLists, key.getCols()); + } assert op.getNumChild() == 1;