建站
咨詢
售后
建站咨詢
新聞中心
本文以Hadoop框架為例，介紹了framework與executor向mesos注冊過程。
成都創(chuàng)新互聯(lián)致力于互聯(lián)網(wǎng)網(wǎng)站建設與網(wǎng)站營銷，提供網(wǎng)站設計制作、成都網(wǎng)站設計、網(wǎng)站開發(fā)、seo優(yōu)化、網(wǎng)站排名、互聯(lián)網(wǎng)營銷、小程序設計、公眾號商城、等建站開發(fā)，成都創(chuàng)新互聯(lián)網(wǎng)站建設策劃專家，為不同類型的客戶提供良好的互聯(lián)網(wǎng)應用定制解決方案，幫助客戶在新的全球化互聯(lián)網(wǎng)環(huán)境中保持優(yōu)勢。
1. Framework注冊過程
（1） JobTracker啟動時，會調(diào)用MesosScheduler的start()方法
（2） MesosScheduler的start()方法創(chuàng)建一個MesosSchedulerDriver對象，并將自己作為參數(shù)傳入該對象。
（3） MesosSchedulerDriver初始化，創(chuàng)建一個SchedulerProcess對象
（4） MesosSchedulerDriver初始化，調(diào)用MasterDetector::create()，它將向SchedulerProcess對象發(fā)送一個NewMasterDetectedMessage消息
（5） SchedulerProcess對象收到NewMasterDetectedMessage消息后，向Master發(fā)送一個RegisterFrameworkMessage消息
（6） Master收到該消息后，保存相關信息，并返回FrameworkRegistedMessage消息，確認framework注冊成功
2. Executor注冊過程
本節(jié)描述框架frameworkX在某個slaveX上注冊executor executorX的過程：
（1）Master***次向slaveX發(fā)送執(zhí)行frameworkX中task的消息 RunTaskMessage
（2）slave收到該消息后，運行相應的消息處理函數(shù)runTask()
（3）該函數(shù)發(fā)現(xiàn)該slave上未啟動frameworkX對應的executorX，則調(diào)用IsolationModule的lauchExecutor()函數(shù)
（4）該函數(shù)創(chuàng)建一個FrameworkExecutor對象，并調(diào)用ExecutorProcess的Initialize()函數(shù)進行初始化，同時啟動TaskTracker
（5）Initialize()函數(shù)創(chuàng)建消息RegisterExecutorMessage，并發(fā)送給slave
（6）Slave收到該消息后，調(diào)用對象的消息處理函數(shù)registerExecutor，該函數(shù)創(chuàng)建ExecutorRegisteredMessage消息，返回給ExecutorProcess
（7）ExecutorProcess收到該消息后，調(diào)用對應的消息處理函數(shù)registered()，該函數(shù)再進一步調(diào)用FrameworkExecutor的registered()函數(shù)
接下來，master發(fā)送給slave的RunTaskMessage消息依次經(jīng)過的流程如下圖所示。需要注意的是，對于同一個計算框 架，Mesos在一個slave上只會創(chuàng)建一個資源container，所有task全部在這個container里運行，也就是說，mesos無法做到 task級別的隔離，只能做到executor級別的隔離，而對于同一個框架，同一個slave上所有task全部在一個executor中運行。
對于Hadoop而言，每個mesos-slave上只會創(chuàng)建一個TaskTracker，且該TaskTracker會被放置到一個 executor（對應一個linux container）中運行，而同一個TaskTracker上所有task均在該TaskTracker所在進程樹中，因而共享該executor對應 的資源。當TaskTracker接收到新的task時，會增加該executor可以使用的資源量（使用“l(fā)xc-cgroup –n %s %s %lld”），而當有task運行完成時，則減少該executor可使用的資源量（使用“l(fā)xc-cgroup –n %s %s %lld”）。
原文鏈接：http://dongxicheng.org/apache-mesos/apache-mesos-framework-executor-registering/
網(wǎng)站欄目：Mesos的Framework與Executor注冊過程
當前路徑：http://www.5511xx.com/article/dhjpodd.html
