Search code examples
apache-flink

Is there an API to reflect on Flink savepoints?


I have a Flink savepoint. I would like to produce a report on it using an API preferably in Java. Thinking of the savepoint like a database, I would like to list the tables, the table schemas, the size of each table in terms of rows and bytes and to produce statistics on the row sizes in bytes (min, max, average, std. dev., etc.). The API described here assumes that the db schema is known (continuing the db analogy). Is there an API to do this?


Solution

  • As far as I know, Flink is no such API. normally savepoint should not be a reporter. I recommend using custom metrics do it. see: https://ci.apache.org/projects/flink/flink-docs-release-1.13/docs/ops/metrics/.(I really want to add a comment, but I dont have enough reputation, I hope it won't bother you)