一、下载
在Flink 官网下载Flink 1.14,完整的安装包名是:flink-1.14.4-bin-scala_2.11.tgz。
二、master 配置
解压安装包,编辑conf/flink-conf.yaml文件:
vim conf/flink-conf.yaml
jobmanager.rpc.address: 172.21.0.XX
taskmanager.numberOfTaskSlots: 2
web.submit.enable: true
jobmanager.rpc.address 为master机器的IP,也可以是master的机器名;taskmanager.numberOfTaskSlots 为在master上运行几个taskslots,可以根据机器的配置来确定此值;web.submit.enable 为是否允许在web上提交任务。
编辑conf/master
vim conf/master
172.21.0.XX:8081
其值是:master 的ip和端口号,也可以写master的机器名;
编辑conf/workers
vim con/wokers
172.21.0.3X
172.21.0.3X
172.21.0.3X
第一行是master 的ip,余下两行是slaver的ip。
slaver 配置
各slaver的配置同master,也是修改三个文件:conf/flink-conf.yaml、conf/master、conf/slaver。
启动集群
在master 上执行:
/data/soft/flink-1.14.0/bin/start-cluster.sh
各slaver会自动启动 TaskManagerRunner 进程。
WEB 访问
打开浏览器,地址栏中输入:http://{master IP}:8081/#/job/running。
点击 task-manager,会有如下界面:
这里不会展示master。
Overvier 界面如下:
参考:
https://blog.csdn.net/wtl1992/article/details/121307695