1,准备三台机器
装好 jdk 等必要的组件。
注意,由于本身没有额外的 dns做转发。因此,需要在每台机器的 host 文件里,配置好相关 ip
具体方法
vim /etc/hosts
2,flink做配置
2.1 资源规划
节点服务器 | node01 | node02 | node03 |
角色 | JobManager TaskManager | TaskManager | TaskManager |
2.2 下载 flink-1.19.0-bin-scala_2.12.tgz的包,并上传解压
下载地址
解压命令
tar xzvf flink-1.19.0-bin-scala_2.12.tgz
2.3 编辑相关配置信息
分别在 node01 、 node02以及 node03上
cd flink-1.19.0/conf
vim config.yaml
# JobManager节点地址.
jobmanager.rpc.address: node01
jobmanager.bind-host: 0.0.0.0
rest.address: node01
rest.bind-address: 0.0.0.0
# TaskManager节点地址.需要配置为当前机器名
taskmanager.bind-host: 0.0.0.0
taskmanager.host: node01
vim workers
node01
node02
node03
vim masters
node01:8081
注意,在 node02 和 node03节点上,只需要编辑对应的 config.yaml 文件中的taskmanager.host属性,node02改为 node02,node03 改为 node03.
2.4依次启动三台 flink
bin/start-cluster.sh
3,访问 webUI
访问 jobManager 所在的 8081 端口,即可打开相关管理页面
http://node01:8081/#/overview
4,问题
如果外部机器无法访问上述地址。可能是防火墙的原因
放通 8081 的防火墙就行。