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
  • 相关阅读:
    垃圾回收机制,正则模块
    日常模块
    文件路径带有字符串的处理方法
    QT进制之间的相互转换
    4-7 selectors模块
    4-5 异步IO模型
    4-4 多路复用IO模型
    4-3 非阻塞IO
    4-2 阻塞IO
    4-1 IO模型介绍
  • 原文地址:https://www.cnblogs.com/gzgBlog/p/14928111.html
Copyright © 2011-2022 走看看