You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by al...@apache.org on 2017/10/10 13:57:33 UTC
flink git commit: [hotfix] Remove exception stack trace from Emitter
shutdown message
Repository: flink
Updated Branches:
refs/heads/master bbd8eee34 -> a803dc7e7
[hotfix] Remove exception stack trace from Emitter shutdown message
Before, we were printing the exception (and stack trace) when the Async
I/O Emitter was receving an interrupted exception. The interrupt,
however is part of the normal shutdown process of the Emitter and the
log message was causing concern because a stack trace usually indicates
something went wrong.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/a803dc7e
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/a803dc7e
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/a803dc7e
Branch: refs/heads/master
Commit: a803dc7e798461ed02f26cf437eee7a644b58cbc
Parents: bbd8eee
Author: Aljoscha Krettek <al...@gmail.com>
Authored: Tue Oct 10 15:54:11 2017 +0200
Committer: Aljoscha Krettek <al...@gmail.com>
Committed: Tue Oct 10 15:54:11 2017 +0200
----------------------------------------------------------------------
.../org/apache/flink/streaming/api/operators/async/Emitter.java | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/a803dc7e/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/Emitter.java
----------------------------------------------------------------------
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/Emitter.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/Emitter.java
index 0a1a2db..53a3eca 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/Emitter.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/operators/async/Emitter.java
@@ -89,8 +89,7 @@ public class Emitter<OUT> implements Runnable {
operatorActions.failOperator(e);
} else {
// Thread got interrupted which means that it should shut down
- LOG.debug("Emitter thread got interrupted. This indicates that the emitter should " +
- "shut down.", e);
+ LOG.debug("Emitter thread got interrupted, shutting down.");
}
} catch (Throwable t) {
operatorActions.failOperator(new Exception("AsyncWaitOperator's emitter caught an " +