赞
踩
集群规划
192.168.25.127 | 192.168.25.128 | 192.168.25.129 |
---|---|---|
JobManager+TaskManager | TaskManager | TaskManager |
1.基础环境jdk1.8及以上
2.使用Flink1.7.2版本
三台机器照下面做
3.修改/conf/flink-conf.yaml 文件
- # 192.168.25.127 为jobmanager管理集群
- jobmanager.rpc.address: 192.168.25.127
- # 每个taskmanager的任务槽,一般和cpu核数相同
- taskmanager.numberOfTaskSlots: 2
4. 修改/conf/masters 文件
- # 配置master节点即为jobmanager地址
- 192.168.25.127:8081
5.修改/conf/slaves 文件
-
- # taskmanager
- 192.168.25.127
- 192.168.25.128
- 192.168.25.129
6.配置flink环境变量
- vim /etc/profile
-
- export FLINK_HOME=/home/wx/opt/module/flink-1.7.2-hadoop
- export PATH=$PATH:$FLINK_HOME/bin
-
-
- source /etc/profile
7.standalone模式启动
- # bin目录下执行
-
- ./start-cluster.sh
8.jps进程查看核实
- # TaskManagerRunner为taskmanager进程
- # StandaloneSessionClusterEntrypoint为jobmanager进程
- 3857 TaskManagerRunner
- 3411 StandaloneSessionClusterEntrypoint
- 3914 Jps
9.查看Flink的web页面 ip:8081/#/overview
10.提交测试jar
赞
踩
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。