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集群

  1. 配置master节点
    配置Master节点就是配置JobManager节点,在$FLINK_HOME/conf/masters文件中配置
hadoop01:8081
  1. 配置worker节点
    配置Worker节点就是配置TaskManager节点,在$FLINK_HOME/conf/workers文件中配置taskManager节点如下:
hadoop01
hadoop02
hadoop03
  1. 配置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
  1. 启动集群
    bin/start-cluster.sh
    
  2. 访问http://192.28.4.26:8081进入flink WEBUI
    image-GsLZ.png
文章作者: 热心网民詹Sir
版权声明: 本站所有文章除特别声明外,均采用 CC BY-NC-SA 4.0 许可协议。转载请注明来自 编程之家
大数据 flink
喜欢就支持一下吧