当前位置:网站首页>Flink cluster configuration

Flink cluster configuration

2022-07-05 04:46:00 Xeon_ CC

install flink1.14.4 Version and unzip
Prepare three virtual machines :
192.168.1.244(master)
192.168.1.245
192.168.1.246

Go to configuration directory

cd /opt/flink-1.14.4/conf

Edit profile

 vi flink-conf.yaml

Configuration item
If in 245 Configuration on host , change ip That's it ,246 And so on .

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

edit masters file

vi masters

Input content
This configuration item is in 244、245、246 All hosts are the same

192.168.1.244:8081

edit workers file

vi workers

Input content
This configuration item is in 244、245、246 The host is also the same

192.168.1.245
192.168.1.246

Configure environment variables

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

add to hadoop Support
Into the Flink Official website
https://flink.apache.org/downloads.html#additional-components
find Additional Components
Click on Pre-bundled Hadoop 2.7.5 (asc, sha1) download jar package
Download it okay jar Package is copied to the flink Installation directory lib Under the directory .

原网站

版权声明
本文为[Xeon_ CC]所创,转载请带上原文链接,感谢
https://yzsam.com/2022/186/202207050437438124.html