Spark2.3.2源码解析： 10. 调度系统 Task任务提交 （三） TaskScheduler : Executor 任务提交

架构图：     Standalone模式提交运行流程图：     首先写一个WordCount代码（这个代码，为了观察多个stage操作，我写了两个reducebykey 函数） 源代码：   直接执行代码，查看spark执行程序时，将代码划分stage生成的DAG流程图   可知： WordCount 在stage划分的时候，划分为三个stage  即在代码中如下标识：   本文继续说task

>>阅读原文<<