有两个与保存点相关的rest API：
post/jobs/：jobid/savepoints，它触发异步保存点操作并返回触发器id。
get/jobs/：jobid/savepoints/：triggerid，它通过触发器id返回操作的状态。
但在分布式系统中，如果操作成功启动，但响应丢失（例如，由于网络问题），那么触发器id丢失，就无法确定操作的状态。
想知道有没有办法列出flink保存点操作？这样我就可以得到触发器id，然后得到操作状态。
有两个与保存点相关的rest API：
post/jobs/：jobid/savepoints，它触发异步保存点操作并返回触发器id。
get/jobs/：jobid/savepoints/：triggerid，它通过触发器id返回操作的状态。
但在分布式系统中，如果操作成功启动，但响应丢失（例如，由于网络问题），那么触发器id丢失，就无法确定操作的状态。
想知道有没有办法列出flink保存点操作？这样我就可以得到触发器id，然后得到操作状态。
1条答案
按热度按时间yizd12fk1#
我知道的唯一方法（除了迭代savepoints dir之外）是使用rest接口获取检查点历史并过滤出保存点：https://ci.apache.org/projects/flink/flink-docs-stable/monitoring/rest_api.html#jobs-作业ID检查点
缺点：你只能得到最后10个检查点：-(