了解纱线环境中的TaskManager和任务槽

Question

我对Flink很陌生，也没有机会阅读Flink源代码来理解源代码的JobManager、TaskManager和任务槽。

我曾经想过，TaskManager进程就像星火的执行者进程，而JobManager进程就像星火的驱动进程

但是当我看图表时，https://learning.oreilly.com/library/view/stream-processing-with/9781491974285/assets/components.png

看来我的想法不对？在纱线容器中运行的是任务槽进程？也就是说，任务槽类似于Spark的executor进程。

我对JobManager、TaskManager和、没有很好或清晰的理解

Answer 1

Flink文档解释了如何组织分布式运行时。粗略地说，与星火相比：

• 任务经理:火花工
• 任务槽:火花任务
• 应用:火花驱动程序

至于Flink的“工作经理”，直到最近(Flink 1.6)，这还是一个扮演着许多角色的单身汉。现在它已经被重构了，它仍然负责大多数独立于集群框架的集群范围的关注点--这意味着协调检查点、恢复和调度。

还请参阅此问题的答案。