Spark中Stage任務劃分源碼跟蹤並簡單解析|任務提交階段|Stage劃分階段|Task提交階段

作業提交階段 進入到collect()方法中 進入到runJob()方法中 繼續進入runJob()方法中 進入到runJob()方法中 進入到runJob()中 進入到dagScheduler.runJob()方法中 進入到submitJob()方法中 進入到post方法中 找到eventQueue的實現類(ctrl + h) Stage劃分階段 找到onReceive類中的doOnReceiv

>>阅读原文<<