热线电话:13121318867

登录
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.0000
1
关注作者
收藏
评论(0)

发表评论

暂无数据
推荐帖子