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 <[email protected]> Authored: Tue Oct 10 15:54:11 2017 +0200 Committer: Aljoscha Krettek <[email protected]> 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 " +
