Flink 基本组件

Flink 基本组件

Posted by danfeng on October 13, 2018

Flink基本组件

  • JobManager 主要工作是协调分布式系统的运行。比如协调各个任务的执行时间,管理 checkpoint 和协调异常状态的恢复等。

  • TaskManager 是任务的真正执行者,包括数据流的缓存和交换等操作。

  • client 不是 Flink Runtime 的一部分,也不参与任务的真正执行,只是用来启动 Job 时生成执行计划并交给 JobManager image