当前位置:   article > 正文

Flink:StandAlone模式部署_flink standalone 部署

flink standalone 部署

集群规划

192.168.25.127192.168.25.128192.168.25.129
JobManager+TaskManagerTaskManagerTaskManager

1.基础环境jdk1.8及以上

2.使用Flink1.7.2版本

三台机器照下面做

3.修改/conf/flink-conf.yaml 文件

  1. # 192.168.25.127 为jobmanager管理集群
  2. jobmanager.rpc.address: 192.168.25.127
  3. # 每个taskmanager的任务槽,一般和cpu核数相同
  4. taskmanager.numberOfTaskSlots: 2

4. 修改/conf/masters 文件

  1. # 配置master节点即为jobmanager地址
  2. 192.168.25.127:8081

5.修改/conf/slaves 文件

  1. # taskmanager
  2. 192.168.25.127
  3. 192.168.25.128
  4. 192.168.25.129

6.配置flink环境变量

  1. vim /etc/profile
  2. export FLINK_HOME=/home/wx/opt/module/flink-1.7.2-hadoop
  3. export PATH=$PATH:$FLINK_HOME/bin
  4. source /etc/profile

7.standalone模式启动

  1. # bin目录下执行
  2. ./start-cluster.sh

 8.jps进程查看核实

  1. # TaskManagerRunner为taskmanager进程
  2. # StandaloneSessionClusterEntrypoint为jobmanager进程
  3. 3857 TaskManagerRunner
  4. 3411 StandaloneSessionClusterEntrypoint
  5. 3914 Jps

9.查看Flink的web页面 ip:8081/#/overview

10.提交测试jar

声明:本文内容由网友自发贡献,不代表【wpsshop博客】立场,版权归原作者所有,本站不承担相应法律责任。如您发现有侵权的内容,请联系我们。转载请注明出处:https://www.wpsshop.cn/w/不正经/article/detail/625399
推荐阅读
相关标签
  

闽ICP备14008679号