当前位置:网站首页>[Flink] Flink builds clusters in standalone mode
[Flink] Flink builds clusters in standalone mode
2022-07-27 10:24:00 【No bug is the biggest bug】
What I use here is Flink1.13.0 Version of ,JDK1.8
Here are two servers , One is used to manage tasks (JobManager), One is used to perform tasks (TaskManager ),
One server for task management , The server that executes the task can expand the node unlimited according to the actual demand !!!
First go Flink Download the package on the official website https://archive.apache.org/dist/flink/flink-1.13.0/flink-1.13.0-src.tgz
Then upload the file to liunx System and unzip

Input instruction cd flink-1.13.0/conf/ Get into conf Catalog

Input instruction vim flink-conf.yaml edit conf file , This file is the core configuration file
Change the address here to Manage the task server by yourself IP Save the address and exit

Input vim masters Edit the file , This file is used to specify Flink The console address of , Default localhost
Write to the management task server IP address

Input vim workers Edit the file , This file is used to configure flink Cluster sub nodes , Default localhost
Write to the execution task server IP Address , Multiple nodes wrap and write multiple

And then through scp Distribute the unzipped package to the sub server !
Enter the management task server bin Catalog

Input ./start-cluster.sh Open clusters

Enter the service password of the child node to start synchronously

Input ./stop-cluster.sh Shut down the cluster
Enter the console to view the cluster status
xxx.xxx.xxx.xxx:8080

attach :
Flink The card slot of each server in can be in conf Configuration in file , The default is 1

If the console cannot be opened, the port may be occupied :
modify conf Change the file to an unused port

At the same time to modify masters file

Just visit the console again !!!
边栏推荐
- mount. Nfs: access denied by server while mounting
- SE(Squeeze and Excitation)模块的理解以及代码实现
- Metaaploit-后渗透技知识
- Sound processing - Mel frequency cepstrum coefficient (MFCC)
- 卸载CUDA11.1
- Xiandai 003
- Matlab- draw bifurcation and chaotic bifurcation diagrams
- Introduction to regular expressions of shell, general matching, special characters: ^, $,., * Character range (brackets): [], special characters: \, matching mobile phone number
- 【英雄哥六月集训】第 23天: 字典树
- DES/3DES/AES区别
猜你喜欢

Shell read read console input, use of read

warning: remote HEAD refers to nonexistent ref, unable to checkout报错信息

pytorch中对BatchNorm2d()函数的理解

分享机器学习笔记(PDF版)+实战项目(数据集+代码)

NVIDIA geforce experience login error: the verifier failed to load. Please check your browser settings, such as the advertisement interceptor (solution)

Oracle查看硬解析
[email protected]@eslint-loader/index.js)解决方法"/>Eslint的报错信息Module Error (from ./node_modules/[email protected]@eslint-loader/index.js)解决方法

Stylegan paper notes + modify code to try 3D point cloud generation

【Flink】Flink进行Standalone模式的集群搭建

warning package.json: No license field报错
随机推荐
RobotFramework+Eclispe环境安装篇
怎样关闭电脑开机自启动的应用
女粉想要找男朋友,竟是为了...
Matlab-创建 MATLAB的logo
Based on LSM tree idea Net 6.0 C # write a kV database (case version)
【英雄哥六月集训】第 28天: 动态规划
Voice data acquisition - real time voice data visualization
How to turn off the application of computer self startup
Matlab-离散事件系统仿真实验
Huawei switch dual uplink networking smart Link Configuration Guide
Stylegan paper notes + modify code to try 3D point cloud generation
Cannot start after installing MySQL 5.7.27 in CentOS 7? (Language bash)
线代004
Vs2019 Community Edition Download tutorial (detailed)
Shell integrated application cases, archiving files, sending messages
Ubuntu and MySQL quick start tutorial
Text processing tool in shell, cut [option parameter] filename Description: the default separator is the built-in variable of tab, awk [option parameter] '/pattern1/{action1}filename and awk
mount.nfs: access denied by server while mounting解决
Overview of PCL modules (1.6)
Matlab/Simulink求解微分方程样例分享