4.2.1. # FLINK环境搭建¶

平台使用的Flink版本为1.7.1：flink-1.7.1-bin-hadoop28-scala_2.11.tgz ## 1.将Flink的tgz包上传到/opt/software目录下 ## 2.解压Flink到/opt/module目录下进入/opt/software目录。执行 tar -zxvf flink-1.7.1-bin-hadoop28-scala_2.11.tgz -C /opt/module ## 3.配置Flink环境变量（1）获取Flink路径 pwd （2）打开/etc/profile文件 vim /etc/profile 在profile文件末尾添加JDK路径 ` #FLINK_HOME export FLINK_HOME=/opt/module/flink-1.7.1 export PATH=$PATH:$FLINK_HOME/bin ` （3）保存退出（4）让修改的配置生效 source /etc/profile

## 4.测试flink是否配置成功执行 flink -v

## 5.修改配置文件信息(/opt/module/flink-1.7.1/conf目录下)

（1）配置flink-conf.yaml vim flink-conf.yaml 修改如下配置： jobmanager.rpc.address: bigdata.master

（2）配置masters vim masters 添加如下配置： bigdata.master:8081

（3）配置slaves vim slaves 添加如下配置： bigdata.slave1 bigdata.slave2

## 6.将flink组件分发给其他机器 scp -r /opt/module/flink-1.7.1 root@bigdata.slave1:/opt/module scp -r /opt/module/flink-1.7.1 root@bigdata.slave2:/opt/module ## 7.启动flink服务在主节点执行/opt/module/flink-1.7.1/bin/start-cluster.sh

## 8.其他服务命令 //停止服务 /opt/module/flink-1.7.1/bin/stop-cluster.sh

//查看服务 jps

主节点显示：StandaloneSessionClusterEntrypoint 从节点显示：TaskManagerRunner