标签:管理器 插槽 Flink JobManager 应用程序 TaskManager 四大 组件 执行
一、作业管理器(JobManager)
1、控制一个应用程序执行的主进程,每个应用程序都会被一个不同的JobManager所控制。
2、JobManager会先接收到应用程序,应用程序包括:作业图(JobGraph)、逻辑数据流图和打包的所有类库和其他资源的Jar包。
3、JobManager会把JobGraph转换成一个物理层面的数据流图,这个图被叫做“执行图”(ExecutionGraph),包含了所有可以并发执行的任务。
4、JobManager会向资源管理器(ResourceManager)请求执行任务必要的资源,也就是任务管理器上的slot。一旦获取到足够的资源,就会将执行图分发到真正运行的TaskManager上。
二、任务管理器(tastManager):
- Flink 中的工作进程。通常在Flink 中会有多个TaskManager运行,每一个TaskManager都包含了一定数量的插槽(slots)。插槽的数量限制了TaskManager能够执行的任务数量。
- 启动之后,TaskManager会向资源管理器注册它的插槽;收到资源管理器的指令后,TaskManager就会将一个或者多个插槽提供给JobManager调用。JobManager就可以向插槽分配任务tasks来执行了。
- 在执行过程中,一个TaskManager可以跟其他运行同一应用程序的TaskManager交换数据。
三、资源管理器(ResourceManager):
- 主要负责管理任务管理器TaskManager的插槽(slots)&
标签:管理器,插槽,Flink,JobManager,应用程序,TaskManager,四大,组件,执行 来源: https://blog.csdn.net/weixin_46163590/article/details/121916330
本站声明: 1. iCode9 技术分享网(下文简称本站)提供的所有内容,仅供技术学习、探讨和分享; 2. 关于本站的所有留言、评论、转载及引用,纯属内容发起人的个人观点,与本站观点和立场无关; 3. 关于本站的所有言论和文字,纯属内容发起人的个人观点,与本站观点和立场无关; 4. 本站文章均是网友提供,不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属;如您发现该文章侵犯了您的权益,可联系我们第一时间进行删除; 5. 本站为非盈利性的个人网站,所有内容不会用来进行牟利,也不会利用任何形式的广告来间接获益,纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。