Details
-
Bug
-
Status: Open
-
Major
-
Resolution: Unresolved
-
0.6.0
-
None
-
None
Description
ShuffleScheduler's shuffleProgressDuration is computed in milliseconds. ShufflePayload's runDuration is computed in microseconds (i.e in OrderedPartitionedKVOutput.generateEventsOnClose())
This would end up in wrong value in computing min-time the reducer should run without getting killed.