特牛生活网

FlinkJob提交流程_fink job 工作流-CSDN博客

网友收藏
文章浏览阅读1.5k次。每个FlinkJob提交的时候,都有特定的流程。通用提交流程(ResourceManager未指定)步骤如下:1.application提交时,被dispatcher分发器将job提交给JobManager2.JobManager向资源管理器ResourceManager申请资源(插槽slot,每个slot为一个线程)3.ResourceManager注册空闲的slot4.由JobManager将slot分配给TaskManager5.job开始执行运行在yarn上的提交流程Fli._fink job 工作流