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 <ches...@apache.org>
Authored: Mon Mar 12 15:08:36 2018 +0100
Committer: zentol <ches...@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);
        }
 }

Reply via email to