MapReduce作业运行过程

 JobClient的runJob()方法:新建JobClient实例,并调用其submitJob()方法。提交作业后,runJob()每秒轮询作业进度,如果发现上次上报后信息有改动,则把进度报告输出到控制台。作业完成,成功则显示作业计数器;失败则输出错误到控制台。   (一)JobClient的submitJob()的作业提交过程: 1. 向JobTracker请求一个新jobID,通过JobT
相关文章
相关标签/搜索