Flink重新发任务,怎么从上一个checkpoint点位启动?
以下为热心网友提供的参考意见
在Flink中,如果需要从上一个checkpoint点位重新启动任务,可以使用flink run
命令的-s
参数指定上次提交的作业ID。具体操作如下:
-
首先,使用
flink list
命令查看已提交的作业列表,找到上次提交的作业ID。 -
然后,使用
flink run -s
命令重新启动任务,其中是上次提交的作业ID。
这样,Flink将从上次提交的checkpoint点位重新启动任务。
以下为热心网友提供的参考意见
启动任务的时候可以指定 ck 地址 也可以指定 sp 地址 两个都可以恢复 ,此回答整理自钉群“【③群】Apache Flink China社区”
本文来自投稿,不代表新手站长_郑州云淘科技有限公司立场,如若转载,请注明出处:https://www.cnzhanzhang.com/22121.html