mapreduce 提交job 流程分析

waitForCompletion() submit(); // 1建立连接     connect();             // 1）创建提交job的代理         new Cluster(getConfiguration());             // （1）判断是本地yarn还是远程             initialize(jobTrackAddr, conf); 

>>阅读原文<<