You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2017/11/28 10:11:46 UTC
flink git commit: [FLINK-8161] [tests] Harden
YARNSessionCapacitySchedulerITCase
Repository: flink
Updated Branches:
refs/heads/master d08b7fe4f -> 7f0c8344c
[FLINK-8161] [tests] Harden YARNSessionCapacitySchedulerITCase
Add "Remote connection to [null] failed with java.nio.channels.NotYetConnectedException"
to the list of whitelisted log statements in YarnTestBase. This logging statement
seems to appear since we moved from Flakka to Akka 2.4.0.
This closes #5085.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/7f0c8344
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/7f0c8344
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/7f0c8344
Branch: refs/heads/master
Commit: 7f0c8344c3bd066085b9aa1564849d7716b1ec7e
Parents: d08b7fe
Author: Till Rohrmann <tr...@apache.org>
Authored: Mon Nov 27 17:31:28 2017 +0100
Committer: Till Rohrmann <tr...@apache.org>
Committed: Tue Nov 28 11:10:57 2017 +0100
----------------------------------------------------------------------
.../java/org/apache/flink/yarn/YarnTestBase.java | 15 ++++++++-------
1 file changed, 8 insertions(+), 7 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/7f0c8344/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 4fc41c4..99df3a4 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
@@ -109,13 +109,14 @@ public abstract class YarnTestBase extends TestLogger {
/** These strings are white-listed, overriding teh prohibited strings. */
protected static final String[] WHITELISTED_STRINGS = {
- "akka.remote.RemoteTransportExceptionNoStackTrace",
- // workaround for annoying InterruptedException logging:
- // https://issues.apache.org/jira/browse/YARN-1022
- "java.lang.InterruptedException",
- // very specific on purpose
- "Remote connection to [null] failed with java.net.ConnectException: Connection refused",
- "java.io.IOException: Connection reset by peer"
+ "akka.remote.RemoteTransportExceptionNoStackTrace",
+ // workaround for annoying InterruptedException logging:
+ // https://issues.apache.org/jira/browse/YARN-1022
+ "java.lang.InterruptedException",
+ // 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"
};
// Temp directory which is deleted after the unit test.