Flink集群配置

安装flink1.14.4版本并解压
准备三台虚拟机：
192.168.1.244（master）
192.168.1.245
192.168.1.246

进入配置目录

cd /opt/flink-1.14.4/conf
1

编辑配置文件

 vi flink-conf.yaml
1

配置项
如果在245的主机上配置，改改ip就行了，246以此类推。

jobmanager.rpc.address: 192.168.1.244
jobmanager.bind-host: 0.0.0.0
taskmanager.bind-host: 0.0.0.0
taskmanager.host: 192.168.1.244
taskmanager.numberOfTaskSlots: 4
rest.address: 0.0.0.0
1
2
3
4
5
6

编辑masters文件

vi masters
1

输入内容
这个配置项目在244、245、246的主机一律相同

192.168.1.244:8081
1

编辑workers文件

vi workers
1

输入内容
这个配置项在244、245、246主机也是一律相同

192.168.1.245
192.168.1.246
1
2

配置环境变量

# Flink
export FLINK_HOME=/opt/flink-1.14.4
export PATH=$PATH:$FLINK_HOME/bin
1
2
3

添加hadoop支持
进Flink官网
https://flink.apache.org/downloads.html#additional-components
找到Additional Components
点击Pre-bundled Hadoop 2.7.5 (asc, sha1)下载jar包
把下载好的jar包复制到flink安装目录的lib目录下即可。