从0到1Flink的成长之路(二十)-Flink 高级特性之状态恢复和重启策略
Posted 熊老二-
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了从0到1Flink的成长之路(二十)-Flink 高级特性之状态恢复和重启策略相关的知识，希望对你有一定的参考价值。
状态恢复和重启策略
手动重启并恢复
1.把程序打包
2.启动Flink集群(本地单机版，集群版都可以)
/export/server/flink/bin/start-cluster.sh
3.访问webUI
http://node1.xxxxx.cn:8081/#/overview
4.使用FlinkWebUI提交
cn.xxxxxx.flink.checkpoint.StreamCheckpointDemo
hdfs://node1.itcast.cn:8020/flink-checkpoint/checkpoint
5.取消任务
6.重新启动任务并指定从哪恢复
cn.xxxxxx.flink.checkpoint.StreamCheckpointDemo
hdfs://node1.itcast.cn:8020/flink-checkpoint/checkpoint
hdfs://node1.itcast.cn:8020/flink-checkpoint/checkpoint/aedbaa962fc720954651d27d95fcb53f/chk-106
7.最后关闭/取消任务
以上是关于从0到1Flink的成长之路(二十)-Flink 高级特性之状态恢复和重启策略的主要内容，如果未能解决你的问题，请参考以下文章
从0到1Flink的成长之路(二十)-Flink 高级特性之状态分类
从0到1Flink的成长之路(二十)-Flink 高级特性之Flink 状态管理
从0到1Flink的成长之路(二十)-Flink 高级特性之 Flink 容错机制