diff --git a/ql/src/java/org/apache/hadoop/hive/ql/parse/GenTezUtils.java b/ql/src/java/org/apache/hadoop/hive/ql/parse/GenTezUtils.java index 5fdb4bdddf..d64f983553 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/parse/GenTezUtils.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/parse/GenTezUtils.java @@ -631,12 +631,12 @@ public static void removeSemiJoinOperator(ParseContext context, } } // Filter operator - filterDynamicValuePredicatesCollection = new DynamicValuePredicateContext(); for (Operator op : ts.getChildOperators()) { if (!(op instanceof FilterOperator)) { continue; } FilterDesc filterDesc = ((FilterOperator) op).getConf(); + filterDynamicValuePredicatesCollection = new DynamicValuePredicateContext(); collectDynamicValuePredicates(filterDesc.getPredicate(), filterDynamicValuePredicatesCollection); for (ExprNodeDesc nodeToRemove : filterDynamicValuePredicatesCollection