学步园

Submit ApplicationStage

1. job.waitForCompletion 
   

2. Job.submit()
   1. final JobSubmitter submitter =getJobSubmitter(cluster.getFileSystem(), cluster.getClient());
   2. submitter.submitJobInternal(Job.this, cluster);

3. 在JobSubmitter.submitJobInternal()
   在本地设置好job的一些参数，取到job
   token等信息，通过inputformat计算输入的split(map)信息

4. ClientProtocol的submitJob
   RPC方法进入到YARNRunner
5. Construct necessary information to start the MR AM
6. Submit to ResourceManager
7. Get the ApplicationId of the submitted application.
8. 在YarnClientImpl中appConect取一个ApplicationId,封装为一个SubmitApplicationRequest由rmClient进行提交，并等待提交后该application状态。
9. ApplicationClientProtocol
   rmClient.submitApplication(request);

RM中协议实现

进入yarn.server.resourcemanager包  ClientRMService

1. 安全用户校验
2. ApplicationId校验
3. 取出request中的queue,ApplicationName,ApplicationType等信息，由rmAppManager
   -> submit

在RMAppManager中根据请求信息创建RMAppImpl实例

4. SubmitApplicationResponse response = recordFactory.newRecordInstance(SubmitApplicationResponse.class);