2019-02-25
阅读量:
752
spark中如何划分stage?
spark中如何划分stage?
答: Spark任务会根据RDD之间的依赖关系,形成一个DAG有向无环图,DAG会提交给DAGScheduler,DAGScheduler会把DAG划分相互依赖的多个stage,划分stage的依据就是RDD之间的宽窄依赖。遇到宽依赖就划分stage,每个stage包含一个或多个task任务。然后将这些task以taskSet的形式提交给TaskScheduler运行。
stage是由一组并行的task组成。






评论(0)


暂无数据
推荐帖子
0条评论
1条评论
0条评论