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