Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/5223#discussion_r161243207 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/webmonitor/RestfulGateway.java --- @@ -137,4 +138,21 @@ JobID jobId, @RpcTimeout Time timeout) { throw new UnsupportedOperationException(); } + + /** + * Triggers a savepoint with the given savepoint directory as a target. + * + * @param targetDirectory Target directory for the savepoint. + * @param timeout for the asynchronous operation + * @return A future to the completed checkpoint + * @throws IllegalStateException If no savepoint directory has been + * specified and no default savepoint directory has been + * configured + */ + default CompletableFuture<CompletedCheckpoint> triggerSavepoint( --- End diff -- Cool :-)
---