spark內核揭秘-13-Worker中Executor啟動過程源碼分析

進入Worker類源碼：

可以看出Worker本身是Akka中的1個Actor。

進入Worker類的LaunchExecutor：

從源代碼可以看出Worker節點上要分配CPU和Memory給新的Executor，首先需要創建1個ExecutorRunner：

ExecutorRunner是用于保護executor進程的：

1、進入ExecutorRunner 的start方法：

1.1、進入fetchAndRunExecutor()方法（核心方法）：

2、進入 master ! ExecutorStateChanged(appId, execId, manager.state, None, None)方法：

發送消息給Master：

我們再回到到launchExecutor方法：

進入ExecutorAdded方法：

上面代碼利用Akka 發送ExecutorStateChanged方法給Master

進入 Master 的ExecutorStateChanged方法：

PS:感覺代碼分析的有點亂，不是很理想，希望大家知道，謝謝

生活不易，碼農辛苦
如果您覺得本網站對您的學習有所幫助,可以手機掃描二維碼進行捐贈