Java教程

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

本文主要是介绍从0到1Flink的成长之路(二十)-Flink 高级特性（二）之状态恢复和重启策略，对大家解决编程问题具有一定的参考价值，需要的程序猿们随着小编来一起学习吧！

状态恢复和重启策略

在这里插入图片描述
手动重启并恢复
1.把程序打包
在这里插入图片描述
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

在这里插入图片描述
5.取消任务
在这里插入图片描述
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

在这里插入图片描述
7.最后关闭/取消任务
在这里插入图片描述

这篇关于从0到1Flink的成长之路(二十)-Flink 高级特性（二）之状态恢复和重启策略的文章就介绍到这儿，希望我们推荐的文章对大家有所帮助，也希望大家多多支持为之网！
您可能喜欢
栏目导航