Details
-
Bug
-
Status: Closed
-
Major
-
Resolution: Fixed
-
None
-
None
-
None
-
Reviewed
Description
The method ReduceTask.ReduceCopier.fetchOutputs makes a call to getMapCompletionEvents every iteration of the loop. This should be moved out to a separate thread. This might slow down the shuffle scheduler in some cases since there is a sleep inside the getMapCompletionEvents method.