花瓣小跑 发表于 2024-8-22 19:52:13

Flink学习(八)-Flink 集群搭建

1,准备三台机器

装好 jdk 等必要的组件。
注意,由于自己没有额外的 dns做转发。因此,必要在每台机器的 host 文件里,设置好相关 ip
具体方法
vim /etc/hosts https://i-blog.csdnimg.cn/blog_migrate/005269bc35787c837ba8937d409f9028.png
 
2,flink做设置

2.1 资源规划

节点服务器
node01
node02
node03
角色
JobManager
TaskManager
TaskManager
TaskManager
2.2 下载 flink-1.19.0-bin-scala_2.12.tgz的包,并上传解压

下载地址
解压下令
tar xzvf flink-1.19.0-bin-scala_2.12.tgz https://i-blog.csdnimg.cn/blog_migrate/05a133bfd3868114939e5922491317ed.png 
2.3 编辑相关设置信息

分别在 node01 、 node02以及 node03上
cd flink-1.19.0/conf
vim config.yaml   # JobManager节点地址.
jobmanager.rpc.address: node01
jobmanager.bind-host: 0.0.0.0
rest.address: node01
rest.bind-address: 0.0.0.0
# TaskManager节点地址.必要设置为当前机器名
taskmanager.bind-host: 0.0.0.0
taskmanager.host: node01
vim workers   node01
node02
node03 
vim masters    node01:8081
注意,在 node02 和 node03节点上,只必要编辑对应的 config.yaml 文件中的taskmanager.host属性,node02改为 node02,node03 改为 node03.
https://i-blog.csdnimg.cn/blog_migrate/8345f5e7a513d54d8540d845bcb75097.pnghttps://i-blog.csdnimg.cn/blog_migrate/b59725b048c1aaab45b440616572532c.png
2.4依次启动三台 flink

bin/start-cluster.sh 3,访问 webUI 

访问 jobManager 所在的 8081 端口,即可打开相关管理页面
http://node01:8081/#/overview
https://i-blog.csdnimg.cn/blog_migrate/f1d6b9d29f05bc185bf1859af55ae098.png4,题目

假如外部机器无法访问上述地址。大概是防火墙的缘故原由
放通 8081 的防火墙就行。


免责声明:如果侵犯了您的权益,请联系站长,我们会及时删除侵权内容,谢谢合作!更多信息从访问主页:qidao123.com:ToB企服之家,中国第一个企服评测及商务社交产业平台。
页: [1]
查看完整版本: Flink学习(八)-Flink 集群搭建