Description
The probable reason this happens is because the JobGenerator and JobScheduler start generating jobs with tasks. When the ReceiverTracker submits the task containing receivers, the tasks get assigned according to empty slots, which may be instantaneously available on one node, instead of all the nodes.
The original behavior was that the jobs started only after the receivers are started, thus ensuring that all the slots are free and the receivers are spread evenly across all the nodes.
Attachments
Issue Links
- is superceded by
-
SPARK-8882 A New Receiver Scheduling Mechanism to solve unbalanced receivers
-
- Resolved
-