Details
-
Sub-task
-
Status: Closed
-
Critical
-
Resolution: Fixed
-
None
-
None
-
None
Description
OnFileSortedOutput generates the same event payload for all downstream tasks. As an example, for a simple MR job - the number of copies of this is equal to the number of reduce tasks.
This needs to be done in a clean manner though - since the event model is meant to generate a separate payload for each downstream task.