当前位置:网站首页>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 .
边栏推荐
- Wan broadband access technology V EPON Technology
- [PCL self study: feature9] global aligned spatial distribution (GASD) descriptor (continuously updated)
- 程序员应该怎么学数学
- [groovy] closure (closure call is associated with call method | call () method is defined in interface | call () method is defined in class | code example)
- TPG x AIDU | AI leading talent recruitment plan in progress!
- [crampon programming] lintcode decoding Encyclopedia - 1100 strange printer
- Introduction to RT thread kernel (4) -- clock management
- Flutter 小技巧之 ListView 和 PageView 的各种花式嵌套
- [groovy] closure (closure call | closure default parameter it | code example)
- CUDA Programming atomic operation atomicadd reports error err:msb3721, return code 1
猜你喜欢

Aperçu en direct | Services de conteneurs ACK flexible Prediction Best Practices

C26451: arithmetic overflow: use the operator * on a 4-byte value, and then convert the result to an 8-byte value. To avoid overflow, cast the value to wide type before calling the operator * (io.2)

The principle of attention mechanism and its application in seq2seq (bahadanau attention)
![[groovy] closure (closure as function parameter | code example)](/img/a6/a4ed401acfb61f85eb08daa15a8a80.jpg)
[groovy] closure (closure as function parameter | code example)

2022 thinking of mathematical modeling D problem of American college students / analysis of 2022 American competition D problem

Group counting notes (1) - check code, original complement multiplication and division calculation, floating point calculation

Is $20billion a little less? Cisco is interested in Splunk?

Download the details and sequence of the original data access from the ENA database in EBI

2022-2028 global and Chinese virtual data storage Market Research Report

Looking at Chinese science and technology from the Winter Olympics: what is the mystery of the high-speed camera that the whole people thank?
随机推荐
English topic assignment (27)
【acwing】240. food chain
Components in protective circuit
直播预告 | 容器服务 ACK 弹性预测最佳实践
介绍汉明距离及计算示例
[groovy] closure (closure parameter list rule | default parameter list | do not receive parameters | receive custom parameters)
计组笔记(1)——校验码、原补码乘除计算、浮点数计算
[Business Research Report] Research Report on male consumption trends in other economic times -- with download link
Download the details and sequence of the original data access from the ENA database in EBI
2022-2028 global and Chinese equipment as a Service Market Research Report
jmeter -- 分布式压测
Variable category (automatic, static, register, external)
Qt蓝牙:搜索蓝牙设备的类——QBluetoothDeviceDiscoveryAgent
Introduction to RT thread kernel (5) -- memory management
Sequence diagram of single sign on Certification Center
猿人学第一题
Matplotlib draws three-dimensional scatter and surface graphs
Neural networks and deep learning Chapter 5: convolutional neural networks reading questions
包 类 包的作用域
CSDN body auto generate directory