*flink*依赖*jvm*环境,因此需要先配置*jvm*环境,本文<u>默认*jvm*环境已经配置完成</u>。
本文服务器信息:
①、*192.168.8.222* (JobManager、TaskManager)
②、*192.168.8.223* (TaskManager)
③、*192.168.8.224* (TaskManager)
#### 准备工作
为了端口可以通信,而且在内网环境,因此可直接关闭防火墙。
```bash
systemctl stop firewalld # 关闭防火墙
systemctl disable firewalld # 关闭开机时启动防火墙
```
创建*/opt/pluto*目录,计划将软件安装在此目录中。
```bash
mkdir -p /opt/pluto
```
#### *flink*安装
先在第一台服务器上配置,再分发给其他服务器。
```bash
tar -zxvf flink-1.10.1-bin-scala_2.11.tgz -C /opt/pluto # 解压压缩包
```
一、修改配置文件 */opt/pluto/flink-1.10.1/conf/flink-conf.yaml*
①、修改 *jobmanager.rpc.address*
*jobmanager.rpc.address: 192.168.8.222*
②、修改 *taskmanager.numberOfTaskSlots*
> 这里演示,修改为 2 ,根据机器生产实际情况进行分配。
*taskmanager.numberOfTaskSlots: 2*
二、修改配置文件 */opt/pluto/flink-1.10.1/conf/masters*
*192.168.8.222:8081*
三、修改配置文件 */opt/pluto/flink-1.10.1/conf/slaves*
*192.168.8.222*
*192.168.8.223*
*192.168.8.224*
分发文件到其他服务器
```bash
scp -r /opt/pluto/flink-1.10.1/ root@192.168.8.223:/opt/pluto/
scp -r /opt/pluto/flink-1.10.1/ root@192.168.8.224:/opt/pluto/
```
至此,所有的*flink*配置均已经完成。
启动 *flink* 服务,在服务器*192.168.8.222* (JobManager、TaskManager)上执行启动命令:
```bash
/opt/pluto/flink-1.10.1/bin/start-cluster.sh # 开启集群
```
```bash
/opt/pluto/flink-1.10.1/bin/stop-cluster.sh # 停止集群
```
可使用 `jps` 查看*flink*进程信息
访问Flink的UI界面:[http://192.168.8.222:8081](http://192.168.8.222:8081)