有没有办法以编程方式或通过 REST API 触发保存点?

Is there a way i can trigger savepoint programmatically or via REST API?

我启用了定期触发并推送到 S3 存储桶的检查点。

我能否以编程方式或通过 REST 端点触发保存点,以便使用 state.savepoints.dir 触发保存点并将其保存到 S3?

此保存点的目的是保持已知的稳定状态,并可用于在以后的时间点恢复。

环境:

flink version: 1.12.1
installation on: k8s

提前致谢。

您可以在 REST API 中使用以下路径创建保存点 /jobs/:jobid/savepoints。您显然需要知道要为其触发保存点的作业的 ID。 该请求是一个 POST 请求,正文为:

{
 "cancel-job":[boolean to indicate if job should be stopped,
 "target-directory": [path in which savepoint should be kept
}

您可以参考[文档]了解更多信息。1