diff --git ql/src/java/org/apache/hadoop/hive/ql/optimizer/ReduceSinkMapJoinProc.java ql/src/java/org/apache/hadoop/hive/ql/optimizer/ReduceSinkMapJoinProc.java index 71c766f..62c0ca9 100644 --- ql/src/java/org/apache/hadoop/hive/ql/optimizer/ReduceSinkMapJoinProc.java +++ ql/src/java/org/apache/hadoop/hive/ql/optimizer/ReduceSinkMapJoinProc.java @@ -213,6 +213,12 @@ public static Object processReduceSinkToHashJoin(ReduceSinkOperator parentRS, Ma bucketCount = parentRS.getConf().getNumReducers(); keyCount /= bucketCount; tableSize /= bucketCount; + if (keyCount == 0) { + keyCount = 1; + } + if (tableSize == 0) { + tableSize = 1; + } } } LOG.info("Mapjoin " + mapJoinOp + ", pos: " + pos + " --> " + parentWork.getName() + " ("