Spark在submitStage后如何经过clustermanager调度执行task到Driver接收计算结果的代码解析...

前文: http://humingminghz.iteye.com/blog/2314269 前面先看到了从action入口到如何切分stage, 随后submit stage的过程, 那么既然stage被submit了, 接下来就应该是cluster manager去分配各个任务到prefer location的executor上面去执行了. submitstage的方法, 最终会把当前stag
相关文章
相关标签/搜索