flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From trohrm...@apache.org
Subject flink git commit: [FLINK-8161] [tests] Harden YARNSessionCapacitySchedulerITCase
Date Tue, 28 Nov 2017 10:11:46 GMT
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 <trohrmann@apache.org>
Authored: Mon Nov 27 17:31:28 2017 +0100
Committer: Till Rohrmann <trohrmann@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.


Mime
View raw message