Flink 1.15 集群部署

Posted 响彻天堂丶

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Flink 1.15 集群部署相关的知识,希望对你有一定的参考价值。

集群配置

1 集群规划

节点服务器hadoop1hadoop2hadoop3
角色JobManagerTaskManagerTaskManager

2 解压包

tar -zxvf flink-1.15.0-bin-scala_2.12.tgz
cd /usr/local/flink-1.15.0

3 修改workers 和 masters

vim masters
hadoop1:8081

vim workers
hadoop2
hadoop3

4 修改配置文件

4.1 修改 JobManager 配置文件

vim flink-conf.yaml

# master地址
jobmanager.rpc.address: hadoop1
 
# master端口,不用改
jobmanager.rpc.port: 6123
 
# master地址绑定设置(master节点参数)
jobmanager.bind-host: 0.0.0.0
 
# worker地址绑定设置
taskmanager.bind-host: 0.0.0.0
 
# worker地址(注意:要改成每个worker节点的主机名)
taskmanager.host: localhost
 
# worker槽位数设置
taskmanager.numberOfTaskSlots: 1
 
# 默认并行度
parallelism.default: 1
 
# WEB UI 端口(master节点参数) 放开注释即可
rest.port: 8081
 
# WEB UI 管理地址
rest.address: hadoop1
 
# WEB UI 地址绑定设置,想让外部访问,可以设置具体的IP,或者直接设置成“0.0.0.0”(master节点参数)
rest.bind-address: 0.0.0.0

4.2 同步到其它节点

cd  /usr/local
scp -r flink-1.15.0/  root@hadoop2:/usr/local/
scp -r flink-1.15.0/  root@hadoop3:/usr/local/

4.3 修改TaskManager配置文件

cd /usr/local/flink-1.15.0/conf
vim flink-conf.yaml

#hadoop2
taskmanager.host: hadoop2

#hadoop3
taskmanager.host: hadoop3

5 启动

#hadoop1 
cd /usr/local/flink-1.15.0
bin/start-cluster.sh

6 访问UI

以上是关于Flink 1.15 集群部署的主要内容,如果未能解决你的问题,请参考以下文章

大数据(9b)Flink集群部署

[3] Flink大数据流式处理利剑: Flink的部署架构

[4] Flink大数据流式处理利剑: Flink集群安装和运行

大数据——Flink 中的角色及安装部署

Flink

大数据——Flink 常见面试题整理