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的数量
手机扫一扫
移动阅读更方便
你可能感兴趣的文章