栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 前沿技术 > 大数据 > 大数据系统

Flink的Standalone 集群安装和部署

Flink的Standalone 集群安装和部署

Standalone 是 Flink 的独立部署模式,它不依赖其他平台。
集群规划如下

node1	master+worker1
node2	worker2
node3	worker3

1.解压 Flink 的压缩包

[root@node1 apps]# tar -zxvf flink-1.9.1-bin-scala_2.11.tgz -C /opt/

2.修改配置文件

  • 进入到 conf 目录下,编辑 flink-conf.yaml 配置文件:


    其中:taskmanager.numberOfTaskSlot 参数默认值为 1,修改成 3。表示数每一个 TaskManager 上有 3 个 Slot。

3.编辑 conf/slaves 配置文件

4.分发给另外两台服务器

[root@node1 opt]# scp -r flink-1.9.1/ node2:`pwd`
[root@node1 opt]# scp -r flink-1.9.1/ node3:`pwd`

5.启动 Flink 集群服务

[root@node1 bin]# ./start-cluster.sh 
Starting cluster.
Starting standalonesession daemon on host node1.
Starting taskexecutor daemon on host node1.
Starting taskexecutor daemon on host node2.
Starting taskexecutor daemon on host node3.

6.访问 WebUI

7.通过 WebUI 提交 job 到集群
将项目打包上传


查看 job 执行结果

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

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

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