[JiChu7]手动重启并恢复

1.把程序打包

image.png

2.启动Flink集群(本地单机版,集群版都可以)

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

3.访问webUI

http://node1:8081/#/overview
http://node2:8081/#/overview

4.使用FlinkWebUI提交

cn.itcast.checkpoint.CheckpointDemo01

image.png

5.取消任务

image.png

6.重新启动任务并指定从哪恢复

cn.itcast.checkpoint.CheckpointDemo01
hdfs://node1:8020/flink-checkpoint/checkpoint/9e8ce00dcd557dc03a678732f1552c3a/chk-34

image.png

7.关闭/取消任务

image.png

8.关闭集群

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