# 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