Flink源碼系列——JobManager處理SubmitJob的過程

接《Flink源碼系列——獲取JobGraph的過程》,在獲取到JobGraph後,客戶端會封裝一個SubmitJob消息,並將其提交給JobManager,本文就接着分析,JobManager在收到SubmitJob消息後,對其處理邏輯。JobManager是一個Actor,其對接受到的各類消息的處理入口是handleMessage這個方法,其中對SubmitJob的處理入口以下:數組 over
相關文章
相關標籤/搜索