hadoop job.class 源码分析
2013-11-28 23:03
316 查看
waitForCompletion()方法 里面,提交作业给集群,并且等待作业完成
/*** Submit the job to the cluster and wait for it to finish.* @param verbose print the progress to the user* @return true if the job succeeded* @throws IOException thrown if the communication with the* <code>JobTracker</code> is lost*/public boolean waitForCompletion(boolean verbose) throws IOException, InterruptedException,ClassNotFoundException {if (state == JobState.DEFINE) {submit();}if (verbose) {jobClient.monitorAndPrintJob(conf, info);} else {info.waitForCompletion();}return isSuccessful();}
相关文章推荐
- hadoop的job提交的源码分析
- Hadoop之JobTracker源码分析
- Hadoop源码分析24 JobTracker启动和心跳处理流程
- Hadoop源码分析38 JobClient的线程协作
- hadoop中job提交的源码分析
- Hadoop源码分析25 JobInProgress 主要容器
- Hadoop源码分析26 JobTracker主要容器和线程
- Hadoop源码分析(三)--------------job提交过程分析(3)之job的split过程
- hadoop 源码分析(一) jobClient 提交到JobTracker
- Hadoop源码分析27 JobTracker空载处理心跳
- Hadoop源码分析1: 客户端提交JOB
- Hadoop源码分析28 JobTracker 处理JobClient请求
- hadoop之MapReduce框架JobTracker端心跳机制分析(源码分析第七篇) 推荐
- 【hadoop】 3007-hadoop的提交job的源码分析
- Hadoop提交Job Client端源码分析
- Hadoop2.*源码分析之Job任务提交与执行
- Hadoop源码分析30 JobInProgress 的 TaskInProgress 执行情况
- Hadoop-1.2.1学习之Job创建和提交源码分析
- Hadoop源码分析--MapReduce作业(job)提交源码跟踪
- hadoop yarn的job提交流程源码分析