diff --git a/ql/src/java/org/apache/hadoop/hive/ql/optimizer/DynamicPartitionPruningOptimization.java b/ql/src/java/org/apache/hadoop/hive/ql/optimizer/DynamicPartitionPruningOptimization.java index e6f21e9..ef63526 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/optimizer/DynamicPartitionPruningOptimization.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/optimizer/DynamicPartitionPruningOptimization.java @@ -393,7 +393,7 @@ private boolean generateSemiJoinOperatorPlan(DynamicListContext ctx, ParseContex // we need the expr that generated the key of the reduce sink ExprNodeDesc key = ctx.generator.getConf().getKeyCols().get(ctx.desc.getKeyIndex()); - +/* if (parentOfRS instanceof SelectOperator) { // Make sure the semijoin branch is not on parition column. String internalColName = null; @@ -429,6 +429,7 @@ private boolean generateSemiJoinOperatorPlan(DynamicListContext ctx, ParseContex return false; } } +*/ List keyExprs = new ArrayList(); keyExprs.add(key);