Flink集群环境搭建

环境准备

  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的数量

原文地址:https://www.cnblogs.com/liuzhongfeng/p/8591301.html