MapReduce運行機制

作業的提交 Job的submit()方法創建一個內部的JobSummiter 實例,並且調用其submitJobInternal()方法(參見步驟1)。提交作業後,waitForCompletion()每秒輪詢作業的進度,如果發現自上次報告後有改變,便把進度報告到控制檯。作業完成後,如果成功,就顯示作業計數器;如果失敗,則導致作業失敗的錯誤被記錄到控制檯。 JobSummiter所實現的作業提交過
相關文章
相關標籤/搜索