mapreduce 提交job 流程分析

waitForCompletion() submit(); // 1建立連接     connect();             // 1）創建提交job的代理         new Cluster(getConfiguration());             // （1）判斷是本地yarn還是遠程             initialize(jobTrackAddr, conf); 

>>阅读原文<<