flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ches...@apache.org
Subject flink git commit: [hotfix][tests] Strip CompletionExceptions in MiniClusterClient#guardWithSingleRetry
Date Mon, 12 Mar 2018 14:09:20 GMT
Repository: flink
Updated Branches:
  refs/heads/master 7cea4252e -> d5fc25e67


[hotfix][tests] Strip CompletionExceptions in MiniClusterClient#guardWithSingleRetry


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/d5fc25e6
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/d5fc25e6
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/d5fc25e6

Branch: refs/heads/master
Commit: d5fc25e6773625ba5e92cc6f4dd604f0c089139c
Parents: 7cea425
Author: zentol <chesnay@apache.org>
Authored: Mon Mar 12 15:08:36 2018 +0100
Committer: zentol <chesnay@apache.org>
Committed: Mon Mar 12 15:08:36 2018 +0100

----------------------------------------------------------------------
 .../org/apache/flink/client/program/MiniClusterClient.java     | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/d5fc25e6/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 7475071..f0a7631 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
@@ -38,6 +38,7 @@ import org.apache.flink.runtime.rpc.exceptions.FencingTokenException;
 import org.apache.flink.runtime.util.ExecutorThreadFactory;
 import org.apache.flink.runtime.util.LeaderConnectionInfo;
 import org.apache.flink.runtime.util.LeaderRetrievalUtils;
+import org.apache.flink.util.ExceptionUtils;
 import org.apache.flink.util.FlinkException;
 
 import javax.annotation.Nonnull;
@@ -197,7 +198,10 @@ public class MiniClusterClient extends ClusterClient<MiniClusterClient.MiniClust
 			operation,
 			1,
 			Time.milliseconds(500),
-			throwable -> throwable instanceof FencingTokenException || throwable instanceof AkkaRpcException,
+			throwable -> {
+				Throwable actualException = ExceptionUtils.stripCompletionException(throwable);
+				return actualException instanceof FencingTokenException || actualException instanceof
AkkaRpcException;
+			},
 			executor);
 	}
 }


Mime
View raw message