You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by se...@apache.org on 2017/10/13 00:07:01 UTC
[10/23] hive git commit: HIVE-17464: Fix to be able to disable max
shuffle size DHJ config (Jesus Camacho Rodriguez,
reviewed by Ashutosh Chauhan)
HIVE-17464: Fix to be able to disable max shuffle size DHJ config (Jesus Camacho Rodriguez, reviewed by Ashutosh Chauhan)
Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/63bda8c7
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/63bda8c7
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/63bda8c7
Branch: refs/heads/hive-14535
Commit: 63bda8c7049725b63ee7e81c684abf8f996f69d4
Parents: d9717f5
Author: Jesus Camacho Rodriguez <jc...@apache.org>
Authored: Wed Oct 11 13:02:03 2017 -0700
Committer: Jesus Camacho Rodriguez <jc...@apache.org>
Committed: Wed Oct 11 13:02:17 2017 -0700
----------------------------------------------------------------------
.../org/apache/hadoop/hive/ql/optimizer/ConvertJoinMapJoin.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/63bda8c7/ql/src/java/org/apache/hadoop/hive/ql/optimizer/ConvertJoinMapJoin.java
----------------------------------------------------------------------
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/optimizer/ConvertJoinMapJoin.java b/ql/src/java/org/apache/hadoop/hive/ql/optimizer/ConvertJoinMapJoin.java
index 9412e5f..e24760b 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/optimizer/ConvertJoinMapJoin.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/optimizer/ConvertJoinMapJoin.java
@@ -1112,8 +1112,8 @@ public class ConvertJoinMapJoin implements NodeProcessor {
long max = HiveConf.getLongVar(context.parseContext.getConf(),
HiveConf.ConfVars.HIVECONVERTJOINMAXSHUFFLESIZE);
if (max < 1) {
- // Max is disabled, we can safely return true
- return true;
+ // Max is disabled, we can safely return false
+ return false;
}
// Evaluate
ReduceSinkOperator rsOp = (ReduceSinkOperator) joinOp.getParentOperators().get(position);