Flink運行時之客戶端提交做業圖-下

submitJob方法分析 JobClientActor經過向JobManager的Actor發送SubmitJob消息來提交Job，JobManager接收到消息對象以後，構建一個JobInfo對象以封裝Job的基本信息，而後將這兩個對象傳遞給submitJob方法：php case SubmitJob(jobGraph, listeningBehaviour) => val cli

>>阅读原文<<