[
https://issues.apache.org/jira/browse/FLINK-3369?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15142635#comment-15142635
]
ASF GitHub Bot commented on FLINK-3369:
---------------------------------------
Github user uce commented on the pull request:
https://github.com/apache/flink/pull/1621#issuecomment-182825136
Thanks for looking into it. The remote address is actually part of all the
messages, but I've readded it as an explicit argument. For the local variant,
the address is known at the job manager. I will go ahead and merge this.
> RemoteTransportException should be instance of CancelTaskException
> ------------------------------------------------------------------
>
> Key: FLINK-3369
> URL: https://issues.apache.org/jira/browse/FLINK-3369
> Project: Flink
> Issue Type: Bug
> Reporter: Ufuk Celebi
> Assignee: Ufuk Celebi
> Fix For: 1.0.0
>
>
> {{RemoteTransportException}} is thrown when a consuming task is notified
> about failure at the producer side. This should not be reported as the root
> cause of the job failure. By making it an instance of {{CancelTaskException}}
> it will not be reported as a failure, but as a cancellation.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
