当前位置:网站首页>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 .
边栏推荐
- Is $20billion a little less? Cisco is interested in Splunk?
- PHP读取ini文件并修改内容写入
- Qt蓝牙:搜索蓝牙设备的类——QBluetoothDeviceDiscoveryAgent
- Rk3399 platform development series explanation (network debugging) 7.29 summary of network performance tools
- QT Bluetooth: a class for searching Bluetooth devices -- qbluetooth devicediscoveryagent
- Official announcement! The third cloud native programming challenge is officially launched!
- Solution of circular dependency
- 首席信息官如何利用业务分析构建业务价值?
- How should programmers learn mathematics
- Practice | mobile end practice
猜你喜欢
Manually implement heap sorting -838 Heap sort
直播預告 | 容器服務 ACK 彈性預測最佳實踐
[groovy] closure (closure parameter binding | curry function | rcurry function | ncurry function | code example)
[groovy] closure closure (customize closure parameters | customize a single closure parameter | customize multiple closure parameters | specify the default value of closure parameters)
防护电路中的元器件
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)
Sequence diagram of single sign on Certification Center
File upload bypass summary (upload labs 21 customs clearance tutorial attached)
The remainder operation is a hash function
托管式服务网络:云原生时代的应用体系架构进化
随机推荐
Emlog博客主题模板源码简约好看响应式
WeNet:面向工业落地的E2E语音识别工具
[AI bulletin 20220211] the hard core up owner has built a lidar and detailed AI accelerator
Flutter tips: various fancy nesting of listview and pageview
TPG x AIDU | AI leading talent recruitment plan in progress!
[Business Research Report] top ten trends of science and technology and it in 2022 - with download link
File upload bypass summary (upload labs 21 customs clearance tutorial attached)
The 22nd Spring Festival Gala, an immersive stage for the yuan universe to shine into reality
Group counting notes (1) - check code, original complement multiplication and division calculation, floating point calculation
jmeter -- 分布式压测
Practice | mobile end practice
Special information | real estate and office buildings - 22.1.9
JMeter -- distributed pressure measurement
2022-2028 global and Chinese equipment as a Service Market Research Report
Introduction to RT thread kernel (5) -- memory management
Introduce Hamming distance and calculation examples
Special information | finance, accounting, audit - 22.1.23
函数(基本:参数,返回值)
Manually implement heap sorting -838 Heap sort
介绍汉明距离及计算示例