从0到1Flink的成长之路(二十)-Flink 高级特性(二)之状态恢复和重启策略

状态恢复和重启策略

从0到1Flink的成长之路(二十)-Flink 高级特性(二)之状态恢复和重启策略
手动重启并恢复
1.把程序打包
从0到1Flink的成长之路(二十)-Flink 高级特性(二)之状态恢复和重启策略
2.启动Flink集群(本地单机版,集群版都可以)

/export/server/flink/bin/start-cluster.sh

3.访问webUI

http://node1.itcast.cn:8081/#/overview

4.使用FlinkWebUI提交

cn.itcast.flink.checkpoint.StreamCheckpointDemo
hdfs://node1.itcast.cn:8020/flink-checkpoint/checkpoint

从0到1Flink的成长之路(二十)-Flink 高级特性(二)之状态恢复和重启策略
5.取消任务
从0到1Flink的成长之路(二十)-Flink 高级特性(二)之状态恢复和重启策略
6.重新启动任务并指定从哪恢复

cn.itcast.flink.checkpoint.StreamCheckpointDemo
hdfs://node1.itcast.cn:8020/flink-checkpoint/checkpoint
hdfs://node1.itcast.cn:8020/flink-checkpoint/checkpoint/aedbaa962fc720954651d27d95fcb53f/chk-106

从0到1Flink的成长之路(二十)-Flink 高级特性(二)之状态恢复和重启策略
7.最后关闭/取消任务
从0到1Flink的成长之路(二十)-Flink 高级特性(二)之状态恢复和重启策略

上一篇:报名用户需求分析


下一篇:第5章-实时计算-板块和K线+第6章-实时预警-FlinkCEP