zoukankan      html  css  js  c++  java
  • Flink集群部署

    1.下载安装包,flink-1.12.0-bin-scala_2.12.tgz

    下载地址:https://flink.apache.org/downloads.html

    2.解压安装包,tar -zvxf ./ flink-1.12.0-bin-scala_2.12.tgz -C ../software/

    3.进入flink目录:cd  flink-1.12.0

    4.修改master, vi ./conf/ masters  ,添加连个master服务器ip和端口

    5.修改slaves vi./conf/ slaves,添加slaves服务器信息

    6.修改flink-conf.yaml文件

    high-availability: zookeeper

    high-availability.zookeeper.quorum: 192.168.0.20:2181, 192.168.0.21,192.168.0.22:2181

    high-availability.zookeeper.path.root: /flink

    high-availability.cluster-id: /default_one

    high-availability.zookeeper.storageDir: hdfs:///flink/recovery

    7.修改zoo.cfg 文件:

    server.1=192.168.0.20:2888:3888

    server.2=192.168.0.21:2888:3888

    server.3=192.168.0.22:2888:3888

    8.修改/etc/profile文件,vi /etc/profile

    export FLINK_HOME=/root/software/flink-1.12.0

    export PATH=$FLINK_HOME/bin:$PATH

    9.使profile文件生效,source /etc/profile

    10.flink拷贝到其他节点:

    Scp ./ flink-1.12.0 -r root@192.168.0.22: /root/software/

    Scp ./ flink-1.12.0 -r root@192.168.0.21: /root/software/

    11.155和156两台机器分别配置profile文件

    12.启动flink集群

    /bin/start-cluster.sh

     启动成功后,可打开flink ui界面:192.168.0.20:8081

    author@nohert
  • 相关阅读:
    Python的正则表达式
    Python的异常处理
    Python的类和对象
    Python乘法口诀表
    Python的文件操作
    三层架构介绍和MVC设计模型介绍
    spring的组件使用
    IDEA使用maven搭建spring项目
    Java集合——Collection接口
    Java集合——概述
  • 原文地址:https://www.cnblogs.com/gzgBlog/p/14928111.html
Copyright © 2011-2022 走看看