有没有办法以编程方式或通过 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
我启用了定期触发并推送到 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