spark內(nèi)核揭秘-13-Worker中Executor啟動(dòng)過(guò)程源碼分析

進(jìn)入Worker類源碼：

可以看出Worker本身是Akka中的1個(gè)Actor。

進(jìn)入Worker類的LaunchExecutor：

從源代碼可以看出Worker節(jié)點(diǎn)上要分配CPU和Memory給新的Executor，首先需要?jiǎng)?chuàng)建1個(gè)ExecutorRunner：

ExecutorRunner是用于保護(hù)executor進(jìn)程的：

1、進(jìn)入ExecutorRunner 的start方法：

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

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

發(fā)送消息給Master：

我們?cè)倩氐降絣aunchExecutor方法：

進(jìn)入ExecutorAdded方法：

上面代碼利用Akka 發(fā)送ExecutorStateChanged方法給Master

進(jìn)入 Master 的ExecutorStateChanged方法：

PS:感覺(jué)代碼分析的有點(diǎn)亂，不是很理想，希望大家知道，謝謝

生活不易，碼農(nóng)辛苦
如果您覺(jué)得本網(wǎng)站對(duì)您的學(xué)習(xí)有所幫助,可以手機(jī)掃描二維碼進(jìn)行捐贈(zèng)