[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/29335304 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/29335304 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/29335304 Branch: refs/heads/release-1.5 Commit: 29335304212e270e7f994cd430ff25c64b395cb5 Parents: d86a2f0 Author: zentol <[email protected]> Authored: Tue Mar 6 13:26:59 2018 +0100 Committer: zentol <[email protected]> Committed: Tue Mar 20 10:15:33 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/29335304/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
