集群配置
1 集群规划
节点服务器 hadoop1 hadoop2 hadoop3 角色 JobManager TaskManager TaskManager
2 解压包
tar - zxvf flink- 1.15 .0 - bin- scala_2. 12. tgz
cd / usr/ local/ flink- 1.15 .0
3 修改workers 和 masters
vim masters
hadoop1: 8081
vim workers
hadoop2
hadoop3
4 修改配置文件
4.1 修改 JobManager 配置文件
vim flink- conf. yaml
# master地址
jobmanager. rpc. address: hadoop1
# master端口, 不用改
jobmanager. rpc. port: 6123
# master地址绑定设置(master节点参数)
jobmanager. bind- host: 0.0 .0 .0
# worker地址绑定设置
taskmanager. bind- host: 0.0 .0 .0
# worker地址(注意:要改成每个worker节点的主机名)
taskmanager. host: localhost
# worker槽位数设置
taskmanager. numberOfTaskSlots: 1
# 默认并行度
parallelism. default : 1
# WEB UI 端口(master节点参数) 放开注释即可
rest. port: 8081
# WEB UI 管理地址
rest. address: hadoop1
# WEB UI 地址绑定设置,想让外部访问,可以设置具体的IP ,或者直接设置成“0.0 .0 .0 ”(master节点参数)
rest. bind- address: 0.0 .0 .0
4.2 同步到其它节点
cd / usr/ local
scp - r flink- 1.15 .0 / root@hadoop2 : / usr/ local/
scp - r flink- 1.15 .0 / root@hadoop3 : / usr/ local/
4.3 修改TaskManager配置文件
cd / usr/ local/ flink- 1.15 .0 / conf
vim flink- conf. yaml
#hadoop2
taskmanager. host: hadoop2
#hadoop3
taskmanager. host: hadoop3
5 启动
#hadoop1
cd / usr/ local/ flink- 1.15 .0
bin/ start- cluster. sh
6 访问UI