菜鸟的Spark 源码学习之路 -4 DAGScheduler源码 - part2

上文中分析了DAGScheduler的基本功能Dagscheduler-1，本文主要深入分析一下Job提交和相关处理。 首先看一下相关的方法和数据结构： 这些结构大多都是HashMap。 1. Job的提交过程 首先是在SparkContext.submitJob提交job，调用的是dagScheduler.submitJob方法 /** * Submit a job for executio

>>阅读原文<<