赞
踩
安装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目录下即可。
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。