标签:schedule class tst 源码 提交 set end scheduler job
任务调度可以从一个Action类算子开始,因为Action类算子会触发一个job的执行
划分stage,以taskSet形式提交任务,DAGScheduler 类中getMessingParentStages()方法是切割job划分stage
SPARK 任务调度源码总结
原文地址:https://www.cnblogs.com/xiangyuguan/p/11241151.html