Flink集群搭建(傻瓜式操做)

从下载到部署,从部署到测试,且听我娓娓道来!

前期准备

jave1.8以上
3台机器的ssh要配好
html

首先在官网下载须要的版本,网址在下面:
此次测试使用的是flink1.6.2,Hadoop2.7.2,scala2.11
https://flink.apache.org/downloads.html#all-stable-releases
下载完毕后将安装包上传到linux,并安装
tar -zxvf flink-1.6.2-bin-hadoop27-scala_2.11.tgz -C /usr/local/
在这里插入图片描述
linux

为了方便这里给flink目录改个名
mv flink-1.6.2 flink
进入flink目录下输入下面命令
vim conf/flink-conf.yaml
修改第33行的jobmanager.rpc.address 改为本身的主机名,在修改52行

在这里插入图片描述
在这里插入图片描述

而后在修改conf下的slaves,先清空slaves,在写入两个taskmanager节点,在查看结果(一行一个主机名)
# > slaves
# echo "spark02" >>slaves
# echo "spark03" >>slaves
# cat slaves
将配置好的文件分发给其余机器 须要相同的目录结构
xsync  /usr/local/flink
启动集群
bin/start-cluster.sh
//查看进程
xcall.sh jps
启动后进程如图

在这里插入图片描述

再去web界面查看:

在这里插入图片描述

至此集群搭建成功!