diff --git ql/src/java/org/apache/hadoop/hive/ql/optimizer/physical/CommonJoinResolver.java ql/src/java/org/apache/hadoop/hive/ql/optimizer/physical/CommonJoinResolver.java index b6db32c..73f0e07 100644 --- ql/src/java/org/apache/hadoop/hive/ql/optimizer/physical/CommonJoinResolver.java +++ ql/src/java/org/apache/hadoop/hive/ql/optimizer/physical/CommonJoinResolver.java @@ -571,8 +571,9 @@ private void mergeMapJoinTaskWithMapReduceTask(MapRedTask mapJoinTask, Configura // single job. mergeMapJoinTaskWithMapReduceTask(newTask, conf); } - return newTask; } + + return newTask; } long ThresholdOfSmallTblSizeSum = HiveConf.getLongVar(conf,