FlinkJob提交流程

每個FlinkJob提交的時候,都有特定的流程。 通用提交流程(ResourceManager未指定) 步驟如下: 1.application提交時,被dispatcher分發器將job提交給JobManager 2.JobManager向資源管理器ResourceManager申請資源(插槽slot,每個slot爲一個線程) 3.ResourceManager註冊空閒的slot 4.由JobMa
相關文章
相關標籤/搜索