系统架构

Flink整体架构

• Flink整体架构中，最为重要的是JobManager和TaskManager。JobManager负责管理提交执行的作业，负责管理调度，因此在不开启高可用的情况下，一般只会有一个。TaskManager则是负责执行任务处理数据，所以可以存在多个。

• JobManager和TaskManager的启动方式：
  1. 作为独立的集群（即standalone模式）进程，直接在机器上启动
  2. 在容器中启动
  3. 由yarn、K8S等资源调度平台调度启动

JobManager