diff --git a/ql/src/java/org/apache/hadoop/hive/ql/plan/ExprNodeDescUtils.java b/ql/src/java/org/apache/hadoop/hive/ql/plan/ExprNodeDescUtils.java index 7b232405d1..96fe75869b 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/plan/ExprNodeDescUtils.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/plan/ExprNodeDescUtils.java @@ -18,14 +18,7 @@ package org.apache.hadoop.hive.ql.plan; -import org.apache.hadoop.hive.ql.exec.ColumnInfo; -import org.apache.hadoop.hive.ql.exec.ExprNodeEvaluator; -import org.apache.hadoop.hive.ql.exec.ExprNodeEvaluatorFactory; -import org.apache.hadoop.hive.ql.exec.FunctionRegistry; -import org.apache.hadoop.hive.ql.exec.Operator; -import org.apache.hadoop.hive.ql.exec.ReduceSinkOperator; -import org.apache.hadoop.hive.ql.exec.RowSchema; -import org.apache.hadoop.hive.ql.exec.UDF; +import org.apache.hadoop.hive.ql.exec.*; import org.apache.hadoop.hive.ql.optimizer.ConstantPropagateProcFactory; import org.apache.hadoop.hive.ql.parse.SemanticException; import org.apache.hadoop.hive.ql.udf.generic.GenericUDF; @@ -434,6 +427,9 @@ public static ExprNodeDesc resolveJoinKeysAsRSColumns(ExprNodeDesc source, Opera for (Map.Entry mapEntry : reduceSinkOp.getColumnExprMap().entrySet()) { if (mapEntry.getValue().equals(source)) { String columnInternalName = mapEntry.getKey(); + if(columnInternalName.startsWith(Utilities.ReduceField.VALUE.toString())) { + continue; + } if (source instanceof ExprNodeColumnDesc) { // The join key is a table column. Create the ExprNodeDesc based on this column. ColumnInfo columnInfo = reduceSinkOp.getSchema().getColumnInfo(columnInternalName);