1)下载安装包
2)上传安装包到/root下
3)解压
cd /root
tar -zxvf flink-1.6.2-bin-hadoop28-scala_2.11.tgz -C hd
4)修改配置文件
vi flink-conf.yaml
第33行修改为:
jobmanager.rpc.address: hd110
5)修改slaves
vi slaves
hd111
hd112
6)分发flink到其他机器
cd /root/hd
scp -r flink-1.6.2/ hd111:$PWD
scp -r flink-1.6.2/ hd112:$PWD
7)启动集群
cd /root/hd/flink-1.6.2
bin/start-cluster.sh
8)关闭集群
cd /root/hd/flink-1.6.2
bin/stop-cluster.sh
9)访问ui界面
http://192.168.1.2:8081
网友评论