有没有API反映Flink savepoints?

Is there an API to reflect on Flink savepoints?

我有一个 Flink 保存点。我想使用 API 最好在 Java 中生成关于它的报告。将保存点想象成一个数据库,我想列出 tables、table 模式、每个 table 的行和字节大小,并生成关于以字节为单位的行大小(最小值、最大值、平均值、标准偏差等)。 API 描述的 here 假设 db 模式是已知的(继续 db 类比)。有 API 可以做到这一点吗?

据我所知,Flink 不是这样的API。通常保存点不应该是记者。我建议使用自定义指标来做到这一点。 see: https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/ops/metrics/.(我很想补充评论,但是我的声望不够,希望不要打扰你)