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:37 GMT
Repository: flink
Updated Branches:
  refs/heads/release-1.5 2da0816cb -> ccdfdf5dc


[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/ccdfdf5d
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ccdfdf5d
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/ccdfdf5d

Branch: refs/heads/release-1.5
Commit: ccdfdf5dc9b19de68839be28e8e6adec542430b3
Parents: 2da0816
Author: zentol <chesnay@apache.org>
Authored: Mon Mar 12 15:08:36 2018 +0100
Committer: zentol <chesnay@apache.org>
Committed: Mon Mar 12 15:09:31 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/ccdfdf5d/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