您的位置:首页 > 运维架构

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();}
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: