flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ches...@apache.org
Subject [5/6] flink git commit: [FLINK-8935][tests] Implement MiniClusterClient#triggerSavepoint
Date Tue, 20 Mar 2018 09:17:01 GMT
[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 <chesnay@apache.org>
Authored: Tue Mar 6 13:26:59 2018 +0100
Committer: zentol <chesnay@apache.org>
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


Mime
View raw message