MapReduce的執行流程

(1) 執行Driver的main方法,裏面有個job.waitForCompletion(),在該方法裏面完成任務的準備,主要包括將輸入數據切片並將切片規劃寫到job.split文件裏面,生成運行任務時的配置文件job.xml,將我們寫的mapreduce程序打成jar包。準備好了之後,將任務提交給yarn的resourcemanager。 (2) Resourcemanager收到客戶端提交的
相關文章
相關標籤/搜索