You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by jd...@apache.org on 2018/11/05 21:44:11 UTC

hive git commit: HIVE-20839: "Cannot find field" error during dynamically partitioned hash join (Jason Dere, reviewed by Vineet Garg)

Repository: hive
Updated Branches:
  refs/heads/master b789aebcf -> 12a6f937c


HIVE-20839: "Cannot find field" error during dynamically partitioned hash join (Jason Dere, reviewed by Vineet Garg)


Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/12a6f937
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/12a6f937
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/12a6f937

Branch: refs/heads/master
Commit: 12a6f937cb623ec89e570883010340016c5493a3
Parents: b789aeb
Author: Jason Dere <jd...@hortonworks.com>
Authored: Mon Nov 5 13:43:29 2018 -0800
Committer: Jason Dere <jd...@hortonworks.com>
Committed: Mon Nov 5 13:43:29 2018 -0800

----------------------------------------------------------------------
 ql/src/java/org/apache/hadoop/hive/ql/plan/ExprNodeDescUtils.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hive/blob/12a6f937/ql/src/java/org/apache/hadoop/hive/ql/plan/ExprNodeDescUtils.java
----------------------------------------------------------------------
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 596640e..7b23240 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
@@ -432,7 +432,7 @@ public class ExprNodeDescUtils {
     // 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<String, ExprNodeDesc> 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.