Flink集群环境搭建
阅读原文时间:2023年07月09日阅读:1

  master:171;slave:171,172;flink版本:1.3.0

  下载地址:http://archive.apache.org/dist/flink/flink-1.3.0/

  1.在yita171中,解压flink-1.3.0-bin-hadoop26-scala_2.11.tgz,命令如下:

  2.参数配置修改:conf/flink-conf.yaml

  3.修改master文件

  4.修改slaves文件

  5.配置已经完成,将所有的文件拷贝到yita172上

  在yita171上执行bin/start-cluster.sh(这个命令的相当于先启动jobmanager后在每个  slave上启动TaskManager。命令分别是bin/jobmanager.sh start和bin/taskmanager .sh    start)

  通过打开10.47.184.171:8081打开监控页面,可以看到相关数据:

  运行flink自带的程序WordCount.jar,即执行:

在监控页面的Completed Jobs可以看到完成jobs的数量

手机扫一扫

移动阅读更方便

阿里云服务器
腾讯云服务器
七牛云服务器

你可能感兴趣的文章