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 c274fd7cc9..ebcd80b8c3 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 @@ -430,7 +430,7 @@ public static ExprNodeDesc resolveJoinKeysAsRSColumns(ExprNodeDesc source, Opera // Find the key/value where the ExprNodeDesc value matches the column we are searching for. // The key portion of the entry will be the internal column name for the join key expression. for (Map.Entry mapEntry : reduceSinkOp.getColumnExprMap().entrySet()) { - if (mapEntry.getValue().isSame(source)) { + if (mapEntry.getValue().equals(source)) { String columnInternalName = mapEntry.getKey(); if (source instanceof ExprNodeColumnDesc) { // The join key is a table column. Create the ExprNodeDesc based on this column.