Spark Core Runtime分析: DAGScheduler, TaskScheduler, SchedulerBackend

Spark Runtime裏的主要層次分析,梳理Runtime組件和執行流程, DAGScheduler Job=多個stage,Stage=多個同種task, Task分爲ShuffleMapTask和ResultTask,Dependency分爲ShuffleDependency和NarrowDependency 面向stage的切分,切分依據爲寬依賴 維護waiting jobs和activ
相關文章
相關標籤/搜索