JobManager

JobManager 相当于整个集群的 Master 节点,且整个集群有且仅有一个活跃的 JobManager,负责整个集群的任务管理和资源管理。

TaskManager

TaskManager 相当于整个集群的 Slave 节点,负责具体的任务执行和对应任务在每个节点上的资源申请和管理。
客户端将任务提交到 JobManager,JobManager 根据已注册在 JobManager 中 TaskManager 的资源情况,将任务分配给有资源的 TaskManager 节点,然后启动并运行任务。
TaskManager 从 JobManager 接收任务,然后使用 Slot 资源启动 Task,并建立网络连接,接收和处理数据。
JobManager 负责整个 Flink 集群任务的调度以及资源的管理,从客户端中获取提交的应用,然后根据集群中 TaskManager 上 TaskSlot 的使用情况,为提交的应用分配相应的 TaskSlot 资源并命令 TaskManager 启动从客户端中获取的应用。