FlinkStandaloneHA集群搭建

FlinkStandaloneHA集群搭建

本次安装是基于CDH环境下安装
flink相关jar包下载:flink1.11.1版本下载
hadoop连接jar包:连接包下载直达通道
如果嫌麻烦,百度网盘直达车:
链接: flink相关jar包
提取码:1234

上传flink安装包到指定目录

使用Xftp上传到指定位置

解压jar包

tar -zxvf flink-1.11.1-bin-scala_2.11.tgz

修改配置文件

cd flink-1.11.1/conf/
vim flink-conf.yaml

修改如下配置

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

以防默认8081端口号被占用修改默认端口号
在这里插入图片描述

修改maser配置

vim masters

在这里插入图片描述

实现高可用配置两台主节点

配置workers

vim workers

在这里插入图片描述

下载hadoop连接jar包

cd flink-1.11.1/bin/
wget https://repo.maven.apache.org/maven2/org/apache/flink/flink-shaded-hadoop-2-uber/2.6.5-10.0/flink-shaded-hadoop-2-uber-2.6.5-10.0.jar

如果不想下载最上面有链接地址

分发配置完成flink包

scp -r flink-1.11.1/ srv192:`pwd`
scp -r flink-1.11.1/ srv193:`pwd`

hdfs创建存储的目录文件夹

sudo -u hdfs hadoop fs -chown root /
hadoop fs -mkdir -p /flink/ha
hadoop fs -ls /
hadoop fs -ls /flink

在这里插入图片描述

启动flink

bin/start-cluster.sh

在这里插入图片描述

jps查看是否启动成功

在这里插入图片描述

查看WEBUI页面

http://部署节点IP:8082

在这里插入图片描述

在这里插入图片描述
自此搭建配置完成,自行测试HA,如有疑问请在下方留言,或者私信都可以


版权声明:本文为weixin_51687288原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。