MapReduce作業運行過程

 JobClient的runJob()方法:新建JobClient實例,並調用其submitJob()方法。提交作業後,runJob()每秒輪詢作業進度,如果發現上次上報後信息有改動,則把進度報告輸出到控制檯。作業完成,成功則顯示作業計數器;失敗則輸出錯誤到控制檯。   (一)JobClient的submitJob()的作業提交過程: 1. 向JobTracker請求一個新jobID,通過JobT
相關文章
相關標籤/搜索