Details
-
Bug
-
Status: Open
-
Major
-
Resolution: Unresolved
-
2.6.2
-
None
-
None
Description
if the conf is set to 1, is about to make reduce task to be scheduled only after all map task success
int completedMapsForReduceSlowstart = (int)Math.ceil(reduceSlowStart * totalMaps); if(completedMaps < completedMapsForReduceSlowstart) {} /////////////////////////// int completedMaps = getJob().getCompletedMaps(); /////////////////////////// JobImpl @Override public int getCompletedMaps() { readLock.lock(); try { return succeededMapTaskCount + failedMapTaskCount + killedMapTaskCount; } finally { readLock.unlock(); } }