APP 
DAGSchedulerEventProcessLoop 源码private[scheduler] class DAGSchedulerEventProcessLoop(dagScheduler: DAGScheduler) extends EventLoop[DAGSchedulerEvent]("dag-scheduler-event-loop") with Logging { private[this] val timer = dagScheduler.metricsSource.messageProcessingTimer /** * The main event lo ......
本文摘自 ：https://www.cnblogs.com/
