FlinkJob提交流程

每个FlinkJob提交的时候,都有特定的流程。 通用提交流程(ResourceManager未指定) 步骤如下: 1.application提交时,被dispatcher分发器将job提交给JobManager 2.JobManager向资源管理器ResourceManager申请资源(插槽slot,每个slot为一个线程) 3.ResourceManager注册空闲的slot 4.由JobMa
相关文章
相关标签/搜索