diff --git ql/src/java/org/apache/hadoop/hive/ql/optimizer/physical/CommonJoinTaskDispatcher.java ql/src/java/org/apache/hadoop/hive/ql/optimizer/physical/CommonJoinTaskDispatcher.java index 5ac6338..f2fabad 100644 --- ql/src/java/org/apache/hadoop/hive/ql/optimizer/physical/CommonJoinTaskDispatcher.java +++ ql/src/java/org/apache/hadoop/hive/ql/optimizer/physical/CommonJoinTaskDispatcher.java @@ -488,9 +488,8 @@ public static boolean cannotConvert(long aliasKnownSize, // create map join task and set big table as i MapRedTask newTask = convertTaskToMapJoinTask(newWork, pos); - MapWork mapWork = newTask.getWork().getMapWork(); Operator startOp = joinOp.getParentOperators().get(pos); - Set aliases = GenMapRedUtils.findAliases(mapWork, startOp); + Set aliases = GenMapRedUtils.findAliases(currWork, startOp); long aliasKnownSize = Utilities.sumOf(aliasToSize, aliases); if (cannotConvert(aliasKnownSize, aliasTotalKnownInputSize, ThresholdOfSmallTblSizeSum)) {