赞
踩
【官方文档】https://ci.apache.org/projects/flink/flink-docs-release-1.8/ops/deployment/cluster_setup.html
三台服务器,192.168.112.130作为jobmanager,131与132作为slaver,完成Flink集群。
yum install java-1.8.0-openjdk
首先下载flink1.8.0,并且分别在三台服务器上进行解压。
配置 jobmanager。
找到130下的,flink/conf/flink-conf.yaml 文件,编辑这个文件,找个jobmanager.rpc.address,修改为 0.0.0.0
jobmanager.rpc.address: 0.0.0.0
找到flink/conf/slaver 文件,编辑这个文件,添加内容如下:
192.168.112.131
192.168.112.132
配置slaver。
找到flink/conf/flink-conf.yaml 文件,编辑这个文件,找个jobmanager.rpc.address,修改为 0.0.0.0
jobmanager.rpc.address: 192.168.112.130
找到flink/conf/slaver 文件,编辑这个文件,添加内容如下:
192.168.112.131
192.168.112.132
跳转到flink根目录,然后输入命令如下,启动集群。
bin/start-cluster.sh
可能会提示输入192.168.112.131 对应用户的密码与132用户对应的密码,输入后即可启动flink集群。
分别在130,131,132服务器输入以下命令,查看flink运行情况:
ps aux | grep flink
关闭集群。在130服务器flink根目录下输入命令如下:
bin/stop-cluster.sh
可能要求输入131与132服务器对应用户的密码,输入后即可关闭所有flink。
总的来说flink的集群安装是比较简单的,但是flink的集群启动时,每远程启动一个slaver都需要输入一次密码,为了解决这个问题需要SSH免密登陆。
Smileyan
2019年7月29日
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。