栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

Flink集群搭建-Standalone模式

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

Flink集群搭建-Standalone模式

我这里使用的是Flink1.13.0的版本,JDK1.8

这里准备两台服务器,一台用来管理任务(JobManager),一台用来执行任务(TaskManager ),

管理任务的服务器一台即可,执行任务的服务器后续可根据实际需求无限制扩充节点!!!

首先去Flink官网下载包 https://archive.apache.org/dist/flink/flink-1.13.0/flink-1.13.0-src.tgz

然后上传文件至至liunx系统并解压

 输入指令 cd flink-1.13.0/conf/  进入conf目录

输入指令 vim flink-conf.yaml 编辑conf文件,这个文件是核心配置文件

把这里的地址改为 自己管理任务服务器IP地址然后保存退出

 

输入 vim masters 编辑该文件,这个文件的作用是用来指定Flink的控制台地址,默认localhost

写入管理任务服务器IP地址即可

 

输入 vim workers 编辑该文件,这个文件用来配置flink集群子节点,默认localhost

写入执行任务服务器IP地址,多个节点就换行写入多个

 然后通过 scp 把该解压好的包分发到子服务器即可!

进入管理任务服务器bin目录

输入 ./start-cluster.sh 开启集群

 

 输入子节点服务密码同步启动

输入 ./stop-cluster.sh 关闭集群

进入控制台查看集群状态 

xxx.xxx.xxx.xxx:8080

附:

Flink中每台服务器的卡槽可以在conf文件中配置,默认是1

 

如果遇到控制台无法打开的情况可能是端口占用:

修改conf文件改一个没人用的端口即可

 同时修改 masters 文件

 再次访问控制台即可!!!

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/992577.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号