分布式流处理引擎 Flink#
在本章节将介绍Flink的部署,当前Flink部署的是standalone session模式,各个节点上即将安装的组件如下表所示:
Hostname |
flink1 |
flink2 |
flink3 |
IP |
192.168.1.11 |
192.168.1.12 |
192.168.1.13 |
JobManager |
yes |
no |
no |
TaskManager |
yes |
yes |
yes |
Flink集群部署必须有一个JobManager, TaskManager可以根据需要配置一个或多个。
JobManager Flink集群的协调者(Master),负责接收并解析flink job, 管理TaskManager, 协调checkpoint, 故障恢复等。
TaskManager Flink集群的Worker节点,负责执行计算,管理其所在节点的资源信息。