当前位置:网站首页>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 .
边栏推荐
- 可观测|时序数据降采样在Prometheus实践复盘
- [goweb development] Introduction to authentication modes based on cookies, sessions and JWT tokens
- Raki's notes on reading paper: soft gazetteers for low resource named entity recognition
- The 22nd Spring Festival Gala, an immersive stage for the yuan universe to shine into reality
- 質量體系建設之路的分分合合
- Emlog博客主题模板源码简约好看响应式
- CSDN body auto generate directory
- Debug insights
- 函数(基本:参数,返回值)
- 概率论与数理统计考试重点复习路线
猜你喜欢
Invalid bound statement (not found) in idea -- problem solving
Function (basic: parameter, return value)
3 minutes learn to create Google account and email detailed tutorial!
Managed service network: application architecture evolution in the cloud native Era
Power management bus (pmbus)
Burpsuite grabs app packets
A survey of automatic speech recognition (ASR) research
Looking at Chinese science and technology from the Winter Olympics: what is the mystery of the high-speed camera that the whole people thank?
Solutions and answers for the 2021 Shenzhen cup
计组笔记(1)——校验码、原补码乘除计算、浮点数计算
随机推荐
Pointer function (basic)
Leetcode hot topic Hot 100 day 33: "subset"
首席信息官如何利用业务分析构建业务价值?
Download the details and sequence of the original data access from the ENA database in EBI
JMeter -- distributed pressure measurement
49 pictures and 26 questions explain in detail what is WiFi?
windows下Redis-cluster集群搭建
线上故障突突突?如何紧急诊断、排查与恢复
[groovy] closure (Introduction to closure class closure | closure parametertypes and maximumnumberofparameters member usage)
Debug insights
Neural networks and deep learning Chapter 5: convolutional neural networks reading questions
函數(易錯)
File upload bypass summary (upload labs 21 customs clearance tutorial attached)
Function (error prone)
计组笔记(1)——校验码、原补码乘除计算、浮点数计算
函数(易错)
Fluent objects and lists
Wenet: E2E speech recognition tool for industrial implementation
Data security -- 14 -- Analysis of privacy protection governance
[groovy] closure (closure parameter list rule | default parameter list | do not receive parameters | receive custom parameters)