You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by kg...@apache.org on 2018/10/01 06:53:38 UTC
hive git commit: HIVE-20618: During join selection BucketMapJoin
might be choosen for non bucketed tables (Zoltan Haindrich reviewed by
Ashutosh Chauhan, Deepak Jaiswal)
Repository: hive
Updated Branches:
refs/heads/master 0fca2f459 -> 457080760
HIVE-20618: During join selection BucketMapJoin might be choosen for non bucketed tables (Zoltan Haindrich reviewed by Ashutosh Chauhan, Deepak Jaiswal)
Signed-off-by: Zoltan Haindrich <ki...@rxd.hu>
Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/45708076
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/45708076
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/45708076
Branch: refs/heads/master
Commit: 457080760e6be7afb12100fac03d99fc45419c95
Parents: 0fca2f4
Author: Zoltan Haindrich <ki...@rxd.hu>
Authored: Mon Oct 1 08:52:36 2018 +0200
Committer: Zoltan Haindrich <ki...@rxd.hu>
Committed: Mon Oct 1 08:52:36 2018 +0200
----------------------------------------------------------------------
.../org/apache/hadoop/hive/ql/optimizer/ConvertJoinMapJoin.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hive/blob/45708076/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 55f73c0..5217208 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
@@ -1429,7 +1429,7 @@ public class ConvertJoinMapJoin implements NodeProcessor {
parentOp.getOpTraits().getNumBuckets() : numBuckets;
}
- if (parentOp instanceof ReduceSinkOperator) {
+ if (!useOpTraits && parentOp instanceof ReduceSinkOperator) {
ReduceSinkOperator rs = (ReduceSinkOperator) parentOp;
estimatedBuckets = (estimatedBuckets < rs.getConf().getNumReducers()) ?
rs.getConf().getNumReducers() : estimatedBuckets;