Flink 1.7.0 集群搭建(standalone cluster)

软件要求

• Java 1.7.x 或者更高
• ssh sshd必须运行起来，因为flink用来管理远程的组件

    如果集群不满足全部上述要求，必须进行更新，否则无法搭建flink集群.
如果已经配置了ssh免密和在所有的节点创建了一样的目录结构，那么就可以使用flink脚本来管理一切fink集群事务了。 安装过程如下：

 

环境信息

• 机器三台：IP是192.168.1.6/192.168.1.7/192.168.1.8
• 系统版本：Centos 7
• java版本：java version "1.8.0_162"

 

准备工作

1. 安装scala：

• 下载 

        wget https://downloads.lightbend.com/scala/2.12.8/scala-2.12.8.rpm

• 安装

        rpm -ivh scala-2.12.8.rpm

• 配置环境变量

        export SCALA_HOME=/usr/share/scala

        export PATH=$PATH:$SCALA_HOME/bin

1. 配置SSH免密登陆

        生成ssh密码的命令，直接回车。

 执行本地命令，将公钥分别传输到远程免密机器

 

 

 

        免密登陆配置完毕.

1. 下载Flink安装文件

        安装文件下载地址：https://flink.apache.org/downloads.html

        

集群安装

• 解压安装包，flink-1.7.0-bin-scala_2.12.tgz

• flink-conf.yaml 的修改

填写主节点的地址

 

• masters 的修改

填写master地址

 

 

• slaves的修改

填写slave地址

 

集群启动

• 执行命令 bin/start-cluster.sh 启动集群

 

到这里集群就已经搭建完毕了。