1、執行mapreduce程式---run
2、本次執行將會生成呢個乙個job , 於是jobclient向jobtracker申請乙個jobid 標識該job.
3、jobclient將job需要的資源提交到hdfs中以乙個jobid命名的目錄中，這些資源包括jar
包，配置檔案，inputsplit等
4、jobclient向jobtracker提交這個job
5、jobtracker初始化這個job
6、jobtracker從hdfs中獲取需要的資訊。
7、通過heartbeat獲取可用的datanode，分配tasktracker
8、各個tasktracker向hdfs獲取需要的資源資訊
9、tasktracker執行該任務
10、向hdfs返回執行的結果。
hadoop map reduce 階段筆記
shuffle and sort mr 框架保證 每個 reducer 的輸入都是按照 key 鍵排過序的。shuffle 將map輸出結果送到reducer和排序的功能。1 map 每個map task將結果輸出到環形記憶體緩衝區，當到達一定閾值，則啟動乙個後台程序將快取中的資料 1 按照 red...
Hadoop MapReduce 效能優化
我們時常談論說到mapreduce時，我們都會說它是離線計算框架，磁碟io開銷大，job執行比較慢等等。這一篇部落格，南國系統回顧下mr程式執行慢的原因，以及如何優化mr程式。我們都知道mapreduce是離線計算框架，不同於spark記憶體計算框架模型。乙個標準的mr程式由map方法和reduce...
九 hadoop mapreduce分割槽
一 什麼時候分割槽？1 分割槽的實現 通過繼承partitioner類，實現getpartition方法。public int getpartition key key,value value,int reducetasknumber map結束後得到的每個key value都呼叫該方法，並把key...