DAGSchedulerEventProcessLoop is an event processing daemon thread to handle DAGSchedulerEvents (on a separate thread from the parent DAGScheduler's).
DAGSchedulerEventProcessLoop is registered under the name of dag-scheduler-event-loop.
DAGSchedulerEventProcessLoop uses java.util.concurrent.LinkedBlockingDeque blocking deque that can grow indefinitely.
DAGSchedulerEventProcessLoop takes the following to be created:
DAGSchedulerEventProcessLoop is created when:
- Event: ShuffleMergeFinalized
- Event handler: handleShuffleMergeFinalized
DAGSchedulerEventProcessLoop uses messageProcessingTime timer to measure time of processing events.