Hi, thanks for the answer. I can use the first option (REST API). for some reason it is undocumented in flink documentation (https://ci.apache.org/projects/flink/flink-docs-release-1.3/monitoring/rest_api.html)
regarding the second option, configure each job with an externalized checkpoint directory. I don't see how I can do it. from flink documentation: "The target directory for the externalized checkpoint’s meta data is determined from the configuration key state.checkpoints.dir which, currently, *can only be set via the configuration files.*" do I messing something? do I have another way to configure externalized checkpoint? thanks Aviad -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/