diff --git a/ql/src/java/org/apache/hadoop/hive/ql/ppd/OpProcFactory.java b/ql/src/java/org/apache/hadoop/hive/ql/ppd/OpProcFactory.java index 6f9df53..9c018c9 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/ppd/OpProcFactory.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/ppd/OpProcFactory.java @@ -750,6 +750,8 @@ protected boolean mergeWithChildrenPred(Node nd, OpWalkerInfo owi, } ewi.merge(extractPushdownPreds); logExpr(nd, extractPushdownPreds); + } else if (aliases != null && e.getKey() != null && !aliases.contains(e.getKey())){ + hasUnpushedPredicates = true; } } owi.putPrunedPreds((Operator) nd, ewi);