You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by se...@apache.org on 2018/01/05 18:38:46 UTC
[05/19] flink git commit: [FLINK-8374] [yarn,
tests] Whitelist meaningless exception that may occur during Akka
shutdown.
[FLINK-8374] [yarn,tests] Whitelist meaningless exception that may occur during Akka shutdown.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/c7c72704
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/c7c72704
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/c7c72704
Branch: refs/heads/master
Commit: c7c72704ab8827245d08850edf3d9a448d18097f
Parents: bc2efdd
Author: Stephan Ewen <se...@apache.org>
Authored: Fri Jan 5 14:32:28 2018 +0100
Committer: Stephan Ewen <se...@apache.org>
Committed: Fri Jan 5 19:38:05 2018 +0100
----------------------------------------------------------------------
.../src/test/java/org/apache/flink/yarn/YarnTestBase.java | 7 +++++--
1 file changed, 5 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/c7c72704/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java
----------------------------------------------------------------------
diff --git a/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java b/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java
index 99df3a4..ae39d0a 100644
--- a/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java
+++ b/flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java
@@ -1,4 +1,4 @@
-/**
+/*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
@@ -116,7 +116,10 @@ public abstract class YarnTestBase extends TestLogger {
// very specific on purpose
"Remote connection to [null] failed with java.net.ConnectException: Connection refused",
"Remote connection to [null] failed with java.nio.channels.NotYetConnectedException",
- "java.io.IOException: Connection reset by peer"
+ "java.io.IOException: Connection reset by peer",
+
+ // this can happen in Akka 2.4 on shutdown.
+ "java.util.concurrent.RejectedExecutionException: Worker has already been shutdown"
};
// Temp directory which is deleted after the unit test.