Spark的啟動進程詳解


Master和Worker是執行任務之前存在的進程 (類似於公司)

Driver和Excutor是任務執行之后存在的進程(類似於公司接到項目后才成立的項目小組)

啟動步驟:

  1. 啟動Master資源管理進程和Work進程
  2. 有任務來執行時會啟動Driver進程,然后向Master資源管理進程進行注冊並申請資源
  3. Master資源管理進程分配資源給Worker進程
  4. Work進程開啟Executor進程, Worker進程向Master進程報告Executor的狀態
  5. Executor(持有Driver對象引用)在啟動開始時會先向Driver進行注冊,

注測的目的:

  1. 將執行的Executor放入到Driver的Executor集合中,以便Executor發出心跳檢測信號和Driver進行接收並更新時間后, 進行超時檢測
  2. Driver划分任務后可以分配任務給Driver
  3. Executor注冊完畢后, Driver會划分任務(Task),然后調度任務(Task)給注冊的Executor去執行
  4. Executor執行任務(Task)時會向Driver報告任務執行狀態,直到執行完
  5. 任務執行完后,Executor進程會消失, 最后Driver進程也會向Master進程進行注銷


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM