列出 Flink 保存点操作答案

【问题标题】：List Flink savepoint operations列出 Flink 保存点操作
【发布时间】：2019-10-22 16:14:37
【问题描述】：

有 2 个保存点相关的 REST API：

但是在分布式系统中，如果操作发起成功，但是响应丢失（例如，由于网络问题），那么触发器ID丢失，无法确定操作的状态.

想知道有没有办法列出 Flink 保存点操作？这样我就可以获取触发器ID，然后获取操作状态。

【问题讨论】：

您可以获得检查点历史记录（其中也包含保存点）。但历史记录只包含最后 10 个检查点（不知道是否可以更改）。
我如何知道一个检查点是否是一个保存点？
json响应中每个checkpoint都有一个属性is_savepoint：ci.apache.org/projects/flink/flink-docs-stable/monitoring/…

【解决方案1】：

我知道的唯一方法（除了迭代保存点目录之外）是使用其余接口获取检查点历史记录并过滤掉保存点：https://ci.apache.org/projects/flink/flink-docs-stable/monitoring/rest_api.html#jobs-jobid-checkpoints

缺点：您只能获得最后 10 个检查点 :-(

【讨论】：