Repository: flink
Updated Branches:
  refs/heads/master e22c777f4 -> 760f0bc23


[hotfix] Exclude Netty RejectedExecutionException from end-to-end tests

Netty can throw a RejectedExecutionException when being shut down. This should 
not be
considered a testing failure and, thus, the PR excludes the corresponding log
statement.


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/760f0bc2
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/760f0bc2
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/760f0bc2

Branch: refs/heads/master
Commit: 760f0bc23a29f0cc652e2ca8667bcf577ea038b4
Parents: e22c777
Author: Till Rohrmann <[email protected]>
Authored: Mon Oct 30 11:27:42 2017 +0100
Committer: Till Rohrmann <[email protected]>
Committed: Mon Oct 30 11:34:17 2017 +0100

----------------------------------------------------------------------
 test-infra/end-to-end-test/common.sh | 2 ++
 1 file changed, 2 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/760f0bc2/test-infra/end-to-end-test/common.sh
----------------------------------------------------------------------
diff --git a/test-infra/end-to-end-test/common.sh 
b/test-infra/end-to-end-test/common.sh
index 6d1e963..9a1c79c 100644
--- a/test-infra/end-to-end-test/common.sh
+++ b/test-infra/end-to-end-test/common.sh
@@ -72,6 +72,7 @@ function stop_cluster {
       | grep -v "DisconnectException" \
       | grep -v "AskTimeoutException" \
       | grep -v "WARN  akka.remote.transport.netty.NettyTransport" \
+      | grep -v  "WARN  
org.apache.flink.shaded.akka.org.jboss.netty.channel.DefaultChannelPipeline" \
       | grep -iq "error"; then
     echo "Found error in log files:"
     cat $FLINK_DIR/log/*
@@ -84,6 +85,7 @@ function stop_cluster {
       | grep -v "DisconnectException" \
       | grep -v "AskTimeoutException" \
       | grep -v "WARN  akka.remote.transport.netty.NettyTransport" \
+      | grep -v  "WARN  
org.apache.flink.shaded.akka.org.jboss.netty.channel.DefaultChannelPipeline" \
       | grep -iq "exception"; then
     echo "Found exception in log files:"
     cat $FLINK_DIR/log/*

Reply via email to