diff --git a/ql/src/java/org/apache/hadoop/hive/ql/optimizer/ColumnPrunerProcCtx.java b/ql/src/java/org/apache/hadoop/hive/ql/optimizer/ColumnPrunerProcCtx.java index 8bcb464de540eda7c14a8c6783bb19a09071af7b..2207cfb2efdb4598dc742d3d497146b52ed39fac 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/optimizer/ColumnPrunerProcCtx.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/optimizer/ColumnPrunerProcCtx.java @@ -270,7 +270,7 @@ public void handleFilterUnionChildren(Operator curOp) for (Operator child : curOp.getChildOperators()) { if (child instanceof UnionOperator) { - prunList = prunedColLists.get(child); + prunList = genColLists(curOp, child); if (prunList == null || prunList.size() == 0 || parentPrunList.size() == prunList.size()) { continue; }