【云星数据---Apache Flink实战系列(精品版)】:Apache Flink实战基础0012--flink分布式部署007
2017-11-14 19:13
771 查看
接上文
6. 验证重启成功
6.1 zookeeper客户端验证
ls / ls /flink ls /flink/flink001
6.2 hadoop hdfs上验证
http://192.168.0.12:50070/explorer.html#/flink-metadata
7. 测试jobmanager的HA
1.关闭jobmanager ${FLINK_HOME}/bin/jobmanager.sh stop 2.开启jobmanager ${FLINK_HOME}/bin/jobmanager.sh start
停止qingcheng13上的jobmanager,来模拟jobmanager的crash。一会的时间,系统就选举出了另外的一个
active jobmanager,本次实验选举的是qingcheng12.
8. 使用jobmanager的HA的flink集群
8.1 打开scala-shell
因为此时集群是HA,remote可以填写任意一个jobmanager,它都会被自动转发到active jobmanager上,本次使用的remote参数时qingcheng11,它就能被qingcheng13这个active jobmanager监控到。
${FLINK_HOME}/bin/start-scala-shell.sh remote qingcheng11 6123
8.2 执行一个小程序
val a= benv.fromElements(1, 2, 3, 4) val b= a.map(_*2) val c= a.map(_+5) val d= a.map(_-1) val e= b.union(c).union(d) val f= e.map(_%2==0) f.collect
8.3程序执行效果
相关文章推荐
- 【云星数据---Apache Flink实战系列(精品版)】:Apache Flink实战基础0011--flink分布式部署006
- 【云星数据---Apache Flink实战系列(精品版)】:Apache Flink实战基础0017--IDEA搭建非maven管理的集成开发环境002
- 【云星数据---Apache Flink实战系列(精品版)】:Apache Flink实战基础0019--IDEA搭建maven管理的集成开发环境001
- 【云星数据---Apache Flink实战系列(精品版)】:Apache Flink实战基础0020--IDEA搭建maven管理的集成开发环境002
- 【云星数据---Apache Flink实战系列(精品版)】:Apache Flink实战基础003--flink特性:流处理,批处理珠联璧合
- 【云星数据---Apache Flink实战系列(精品版)】:Apache Flink实战基础002--flink特性:流处理特性介绍
- 【云星数据---Apache Flink实战系列(精品版)】:Apache Flink实战基础004--flink特性:类库和API示例
- 【云星数据---Apache Flink实战系列(精品版)】:Apache Flink实战基础0016--IDEA搭建非maven管理的集成开发环境001
- 【云星数据---Apache Flink实战系列(精品版)】:Apache Flink实战基础0018--IDEA搭建非maven管理的集成开发环境003
- 【云星数据---Apache Flink实战系列(精品版)】:Apache Flink实战基础0013--flink分布式部署008
- 【云星数据---Apache Flink实战系列(精品版)】:Flink基础--001:flink介绍
- 【云星数据---Apache Flink实战系列(精品版)】:Apache Flink实战基础006--flink分布式部署001
- 【云星数据---Apache Flink实战系列(精品版)】:Apache Flink实战基础008--flink分布式部署003
- 【云星数据---Apache Flink实战系列(精品版)】:Apache Flink实战基础007--flink分布式部署002
- 【云星数据---Apache Flink实战系列(精品版)】:Apache Flink实战基础0015--flink分布式部署0010
- 【云星数据---Apache Flink实战系列(精品版)】:Apache Flink批处理API详解与编程实战019--DateSet实用API详解019
- 【云星数据---Apache Flink实战系列(精品版)】:Apache Flink高级特性与高级应用011-Slot和Parallelism的深入分析006
- 【云星数据---Apache Flink实战系列(精品版)】:Apache Flink批处理API详解与编程实战007--DateSet实用API详解007
- 【云星数据---Apache Flink实战系列(精品版)】:Apache Flink高级特性与高级应用001-Flink的内存管理001
- 【云星数据---Apache Flink实战系列(精品版)】:Apache Flink高级特性与高级应用006-Slot和Parallelism的深入分析001