blacklist = new ArrayList<SubClusterId>()
numSubmitRetries
federationFacade.updateApplicationHomeSubCluster(appHomeSubCluster)
return subClusterId
getClientRMProxyForSubCluster(subClusterId)
federationFacade.addApplicationHomeSubCluster(appHomeSubCluster)
appHomeSubCluster
response!=null
submit
activeSubclustersappSubmissionContextblacklist
①：集群策略②：队列策略③：作业调度策略
submitApplication
queue==null
queue = appSubmissionContext.getQueue()
subClusterId
i=0
qilin拿到的数据
i==0
queue = default
和RM创建连接，然后返回response
HomeSubcluster
hadoop-yarn-server-common\\...\outer\\QilinPolicy
appSubmissionContext
!=null
y
i++
选择policy
getHomeSubcluster
return SubClusterId
response = clientRMProxy.submitApplication
applicationId
Router/FederationClientInterceptor
response
hadoop-yarn-server-common\\...\\federation
Client
