当前位置:网站首页>Flink集群配置

Flink集群配置

2022-07-05 04:38:00 Xeon_CC

安装flink1.14.4版本并解压
准备三台虚拟机:
192.168.1.244(master)
192.168.1.245
192.168.1.246

进入配置目录

cd /opt/flink-1.14.4/conf

编辑配置文件

 vi flink-conf.yaml

配置项
如果在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

编辑masters文件

vi masters

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

192.168.1.244:8081

编辑workers文件

vi workers

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

192.168.1.245
192.168.1.246

配置环境变量

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

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

原网站

版权声明
本文为[Xeon_CC]所创,转载请带上原文链接,感谢
https://blog.csdn.net/Xeon_CC/article/details/125552036