当前位置:网站首页>[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 !!!
边栏推荐
- 数据库性能系列之子查询
- Stylegan paper notes + modify code to try 3D point cloud generation
- 女粉想要找男朋友,竟是为了...
- Decision tree principle and case application - Titanic survival prediction
- hdu5289(Assignment)
- Vs2019 Community Edition Download tutorial (detailed)
- Excellent Kalman filter detailed article
- Metaaploit-后渗透技知识
- Sorting out some open source projects of speech recognition
- 分享机器学习笔记(PDF版)+实战项目(数据集+代码)
猜你喜欢

Visual slam lecture notes (I): Lecture 1 + Lecture 2

【Liunx】MariaDB/MySQL定时全量备份脚本及数据恢复

Xiandai 003

NFT system development - Tutorial

Based on LSM tree idea Net 6.0 C # write a kV database (case version)

Metaspolit

卸载CUDA11.1

Configuration of pytorch deep learning environment based on cuda10.0

邮件服务器

Ant高级-path和fileset
随机推荐
【精选】如何完美的写 PHP 代码的呢?
Oracle查看硬解析
es6 class 继承的重点
Pyautogui realizes automatic office -rpa small case
SQL injection
SE(Squeeze and Excitation)模块的理解以及代码实现
Matlab-绘制日期和持续时间图
Reason for pilot importerror: cannot import name 'pilot_ Version 'from' PIL ', how to install pilot < 7.0.0
Establishment of NFS server
Shell read read console input, use of read
数据库操作基础语句
Shell variables, system predefined variables $home, $pwd, $shell, $user, custom variables, special variables $n, $, $*, [email protected],
Matlab-离散事件系统仿真实验
VS2019+CUDA11.1新建项目里没有CUDA选项
Word2vec principle and application and article similarity (recommended system method)
Matlab-实时编辑器介绍
Samba server
Matlab low-level source code realizes the median filtering of the image (used to eliminate some miscellaneous points on the image)
Basic statement of database operation
Oracle调整数据文件大小杂谈