[
https://issues.apache.org/jira/browse/FLINK-13588?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16901925#comment-16901925
]
Till Rohrmann commented on FLINK-13588:
---------------------------------------
I think the rationale is that exceptions which occur after the task has stopped
running should no longer be relevant and hence don't need to be logged.
Exceptions could occur when shutting down the task, for example. This is
expected and should not be reported. Does this make sense [~johnlon]?
> StreamTask.handleAsyncException throws away the exception cause
> ---------------------------------------------------------------
>
> Key: FLINK-13588
> URL: https://issues.apache.org/jira/browse/FLINK-13588
> Project: Flink
> Issue Type: Bug
> Affects Versions: 1.8.1
> Reporter: John Lonergan
> Priority: Major
>
> Code below throws the reason 'message' away making it hard to diagnose why a
> split has failed for instance.
>
> {code:java}
> https://github.com/apache/flink/blob/master/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java#L909
> @Override
> public void handleAsyncException(String message, Throwable exception) {
> if (isRunning) {
> // only fail if the task is still running
> getEnvironment().failExternally(exception);
> }
> }{code}
>
> Need to pass the message through so that we see it in logs please.
>
--
This message was sent by Atlassian JIRA
(v7.6.14#76016)
