Hadoop Job提交流程

submit()

// Submit to ResourceManagerApplicationId applicationId =          resMgrDelegate.submitApplication(appContext);ApplicationReport appMaster = resMgrDelegate          .getApplicationReport(applicationId);

Driver

YarnRunner

JobSubmitter

conf.writeXml(out);

Cluster

Job

//LocalJobRunner / YarnRunnerclientProtocolProvider = provider;client = clientProtocol;

job.waitForComopletion(true)

//建立连接connect（）