- 集群角色分配
Hostname | IP | Role |
hadoop01 | 192.168.126.132 | JobManager TaskManager |
hadoop02 | 192.168.126.133 | TaskManager |
hadoop03 | 192.168.126.134 | TaskManager |
- 下载flink安装包
https://archive.apache.org/dist/flink/flink-1.17.0/
上传至hadoop01并解压:
修改conf/flink-conf.yaml(从flink1.16版本开始,需要修改以下配置)
jobmanager.rpc.address: hadoop01
jobmanager.bind-host: 0.0.0.0
taskmanager.bind-host: 0.0.0.0
taskmanager.host: hadoop01
#用于Web UI,与JobManager保持一致
rest.address: hadoop01
rest.bind-address: 0.0.0.0
修改conf/workers(将三台TaskManager节点加进来)
修改conf/masters(将JobManager节点加进来)
然后将hadoop01节点上的flink包分发至hadoop02和hadoop03。
[root@hadoop01 wyh]# pwd
/usr/local/wyh
[root@hadoop01 wyh]# scp -r flink-1.17.0/ hadoop02:$PWD
[root@hadoop01 wyh]# scp -r flink-1.17.0/ hadoop03:$PWD
修改hadoop02和hadoop03的conf/flink-conf.yaml中的taskmanager.host,改为当前各自的主机名。
taskmanager.host: hadoop02
taskmanager.host: hadoop03
启动集群:
[root@hadoop01 bin]# pwd
/usr/local/wyh/flink-1.17.0/bin
[root@hadoop01 bin]# ./start-cluster.sh
查看进程:
查看Web UI:
http://192.168.126.132:8081/
文章来源:https://www.toymoban.com/news/detail-517221.html
至此,Flink1.17.0集群搭建完成。文章来源地址https://www.toymoban.com/news/detail-517221.html
到了这里,关于Flink 1.17.0集群搭建的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!