Flink

零、前提条件

Flink集群规划

hadoop1	hadoop2	hadoop3
JobManager	TaskManager	TaskManager

上传安装包（在hadoop1操作）

解压安装包

1 2	tar -zxvf /software/flink-1.19.1-bin-scala_2.12.tgz -C /opt ln -s /opt/flink-1.19.1 /opt/flink

配置环境变量，添加如下内容

1 2	export FLINK_HOME=/opt/flink export PATH=$PATH:$FLINK_HOME/bin

让环境变量生效

1	source /etc/profile

验证版本号

flink -v

看到如上版本号字样，说明环境变量配置成功。

一、配置Flink

进入flink配置目录/opt/flink/conf，查看配置文件

配置flink-conf.yaml

1	vim flink-conf.yaml

找到相关配置项并修改，如下

jobmanager.rpc.address: hadoop1
jobmanager.bind-host: 0.0.0.0
taskmanager.bind-host: 0.0.0.0
taskmanager.host: hadoop1
rest.address: hadoop1
rest.port: 8082
rest.bind-address: 0.0.0.0

（下图以rest为例）

配置workers

1	vim workers

把原有内容删除，添加内容如下：

1 2	hadoop2 hadoop3

配置masters

1	vim masters

修改后内容如下：（由于8081端口被Spark占用了，改成8082）

1	hadoop1:8082

确保hadoop2、hadoop3机器已开启的情况下，执行如下分发命令（注意分发的是flink-1.19.1，不是flink）。

scp -r /opt/flink-1.19.1 root@hadoop2:/opt/
scp /etc/profile root@hadoop2:/etc/
scp -r /opt/flink-1.19.1 root@hadoop3:/opt/
scp /etc/profile root@hadoop3:/etc/

让环境变量生效