Spark内核之DAGScheduler调度

Executor启动完了,接下来就准备在executor上执行task了,关于task任务的执行,就是我们接下来要说的TaskScheduler和DAGScheduler了。 TaskScheduler作用是为创建它的SparkContext调度任务,即从DAGScheduler接受不同Stage的任务,并且向集群提交这些任务 DAGScheduler主要负责分析用户提交的应用,并根据计算任务的依
相关文章
相关标签/搜索