diff --git ql/src/java/org/apache/hadoop/hive/ql/optimizer/ConvertJoinMapJoin.java ql/src/java/org/apache/hadoop/hive/ql/optimizer/ConvertJoinMapJoin.java index a2414f3..7b56c91 100644 --- ql/src/java/org/apache/hadoop/hive/ql/optimizer/ConvertJoinMapJoin.java +++ ql/src/java/org/apache/hadoop/hive/ql/optimizer/ConvertJoinMapJoin.java @@ -1110,8 +1110,8 @@ private boolean checkShuffleSizeForLargeTable(JoinOperator joinOp, int position, 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);