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 2019/10/11 16:37:09 UTC

[flink] branch release-1.8 updated: [FLINK-14347][test] Filter out expected exception string in YARN tests

This is an automated email from the ASF dual-hosted git repository.

trohrmann pushed a commit to branch release-1.8
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.8 by this push:
     new 903ac21  [FLINK-14347][test] Filter out expected exception string in YARN tests
903ac21 is described below

commit 903ac2135a0932dacce40f158a9c1a7afd50f564
Author: tison <wa...@gmail.com>
AuthorDate: Fri Oct 11 10:10:43 2019 +0800

    [FLINK-14347][test] Filter out expected exception string in YARN tests
    
    This closes #9880.
---
 flink-yarn-tests/src/test/java/org/apache/flink/yarn/YarnTestBase.java | 3 +++
 1 file changed, 3 insertions(+)

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 fee05fa..94166ed 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
@@ -126,6 +126,9 @@ public abstract class YarnTestBase extends TestLogger {
 		"Remote connection to [null] failed with java.nio.channels.NotYetConnectedException",
 		"java.io.IOException: Connection reset by peer",
 
+		// filter out expected ResourceManagerException caused by intended shutdown request
+		YarnResourceManager.ERROR_MASSAGE_ON_SHUTDOWN_REQUEST,
+
 		// this can happen in Akka 2.4 on shutdown.
 		"java.util.concurrent.RejectedExecutionException: Worker has already been shutdown",