flink1.9.2集群部署
flink1.19.2集群部署
下载flink1.19.2安装包https://www.apache.org/dyn/closer.lua/flink/flink-1.19.2/flink-1.19.2-bin-scala_2.12.tgz
Standalone集群
- 配置master节点
配置Master节点就是配置JobManager节点,在$FLINK_HOME/conf/masters文件中配置
hadoop01:8081
- 配置worker节点
配置Worker节点就是配置TaskManager节点,在$FLINK_HOME/conf/workers文件中配置taskManager节点如下:
hadoop01
hadoop02
hadoop03
- 配置config.yaml文件
其中taskmanger.host另外两台要分别改成hadoop02、hadoop03
jobmanager:
bind-host: 0.0.0.0
rpc:
address: hadoop01
taskmanager:
bind-host: 0.0.0.0
host: hadoop01
rest:
address: hadoop01
bind-address: 0.0.0.0
- 启动集群
bin/start-cluster.sh
- 访问http://192.28.4.26:8081进入flink WEBUI
版权声明:
本站所有文章除特别声明外,均采用 CC BY-NC-SA 4.0 许可协议。转载请注明来自
编程之家!
喜欢就支持一下吧