赞
踩
#部署版本:flink-1.17.2
#Java 1.8 [自行下载参考java安装教程]
#3台服务器 centos 7.0
一、集群之间免密登陆
首先,在某一台服务器上执行生成SSH KEY 命令
ssh-keygen -t rsa(一路回车),到如下图所示:
查看~目录下已经生成了.ssh文件
然后分发公钥文件
ssh-copy-id -i ~/.ssh/id_rsa.pub 需要免密的机器IP(注意:包含本机,三台服务器都要分发)
示例:ssh-copy-id -i ~/.ssh/id_rsa.pub 192.168.119.110
ssh-copy-id -i ~/.ssh/id_rsa.pub 192.168.119.111
ssh-copy-id -i ~/.ssh/id_rsa.pub 192.168.119.112
【每一台服务器都要和其他两台相互免密,在另外两台服务器上重复上面操作】
二、配置FLINK
首先、解压flink
tar -zxvf flink-1.17.2-bin-scala_2.12.tgz
进入conf目录修改flink-conf.yaml、master、worker三个文件
修改内容如下:
##flink-conf.yaml文件修改内容
#JobManager节点地址
jobmanager.rpc.address:192.168.119.110【注意:这里是主节点】
jobmanager.bind-host:0.0.0.0
rest.address:192.168.119.110
rest.bind-address:0.0.0.0
#TaskManager节点地址.需要配置为当前机器名
taskmanager.bind-host:0.0.0.0
taskanager.host:192.168.119.110【这里配置当前服务器IP,另外两个服务器文件分发后需要同步修改成自己的IP】
然后文件分发给另外两台服务器
scp -r 文件目录/文件名 目标文件目录
示例:scp -r /opt/flink/flink-1.17.2 /opt/flink/flink-1.17.2【这里是我的安装目录,目录根据自己安装的目录修改】
##master文件修改内容
192.168.119.110:8081
##修改worker文件修改内容
192.168.119.110
192.168.119.111
192.168.119.112
二、启动FLINK
使用./start-cluster.sh启动,不能使用sh start-cluster.sh,因为在start-cluster.sh中指定的解析器是/usr/bin/env bash,而不是我们常见的shell解析器,所以会出错,一般情况,只要不是shell解析器,都采用“./脚本名”的方式运行脚本,运行后展示以下内容说明启动成功:
主节点110 jps查看结果
主节点111 jps查看结果
主节点112 jps查看结果
登陆主节点192.168.119.110:8081结果【如果启动后无法访问web页面,请参考我之前文章,单节点部署问题汇总无法访问web页面解决方案】
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。