[FLINK-8935][tests] Implement MiniClusterClient#triggerSavepoint
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ca514e16 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ca514e16 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/ca514e16 Branch: refs/heads/master Commit: ca514e16dc36ab01e4051e76948e7cffcf17c56d Parents: 3e6aa67 Author: zentol <[email protected]> Authored: Tue Mar 6 13:26:59 2018 +0100 Committer: zentol <[email protected]> Committed: Tue Mar 20 10:14:26 2018 +0100 ---------------------------------------------------------------------- .../java/org/apache/flink/client/program/MiniClusterClient.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/ca514e16/flink-clients/src/main/java/org/apache/flink/client/program/MiniClusterClient.java ---------------------------------------------------------------------- diff --git a/flink-clients/src/main/java/org/apache/flink/client/program/MiniClusterClient.java b/flink-clients/src/main/java/org/apache/flink/client/program/MiniClusterClient.java index 9c87423..4354267 100644 --- a/flink-clients/src/main/java/org/apache/flink/client/program/MiniClusterClient.java +++ b/flink-clients/src/main/java/org/apache/flink/client/program/MiniClusterClient.java @@ -118,7 +118,7 @@ public class MiniClusterClient extends ClusterClient<MiniClusterClient.MiniClust @Override public CompletableFuture<String> triggerSavepoint(JobID jobId, @Nullable String savepointDirectory) throws FlinkException { - throw new UnsupportedOperationException("MiniClusterClient does not yet support this operation."); + return guardWithSingleRetry(() -> miniCluster.triggerSavepoint(jobId, savepointDirectory, false), scheduledExecutor); } @Override
