Flink 保存点恢复

Question

我们目前在 Kubernetes 中运行 flink。据我了解，每次进行代码部署时，我们都需要创建一个保存点，然后在部署后恢复该保存点。不确定这是否正确。我的脚本当前运行此命令来获取 job_id 并创建一个保存点

kubectl exec -it $JOBMANAGER -- flink stop $JOB_ID -- savepointPath

我正在尝试找到恢复最新保存点的命令。需要jar文件吗？

如有任何帮助，我们将不胜感激。

Answer 1

在某些情况下，可以使用保留的检查点而不是保存点。有关何时需要保存点的详细信息，请参阅文档中的此表。或者，如果您的 Flink 版本足够新，您可以使用本机而不是规范保存点。更喜欢本地保存点（或检查点）的原因是这会减少停机时间。

对于重新启动，您将执行以下操作：

... flink run \
      --detached \ 
      --fromSavepoint /tmp/flink-savepoints/savepoint-cca7bc-bb1e257f0dab \
      ./examples/streaming/StateMachineExample.jar

有关更多信息，请参阅 https://nightlies.apache.org/flink/flink-docs-stable/docs/deployment/cli/#starting-a-job-from-a-savepoint。