博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Flink集群环境搭建
阅读量:7195 次
发布时间:2019-06-29

本文共 522 字,大约阅读时间需要 1 分钟。

环境准备

  master:171;slave:171,172;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

你可能感兴趣的文章
类的数据成员的 const、static等类型的声明和定义常识
查看>>
银行家算法
查看>>
发现一个全部用html5写的网站,里面还有很多知识
查看>>
在php中使用对称加密DES3,开发银行卡绑定,实名验证……
查看>>
Linux history
查看>>
活动安排
查看>>
Python中怎么进行单元测试
查看>>
Laravel之哈希/常用函数/分页
查看>>
spring 事务传播说明
查看>>
Codeforces 442A
查看>>
Please enable network time synchronisation in system settings
查看>>
Android Actionbar Tab 导航模式
查看>>
python+matplotlib+web.py
查看>>
springboot 使用maven 打包 报 (请使用 -source 7 或更高版本以启用 diamond 运算符) 错误解决办法...
查看>>
洛谷 P2290 [HNOI2004]树的计数(bzoj[1211])
查看>>
Linux系统管理
查看>>
virtualbox 相关操作
查看>>
git 和 github 的基本使用
查看>>
流水灯
查看>>
Dubbo系列(2)_RPC介绍
查看>>