Alex created FLINK-14103:
----------------------------
Summary: StreamTask refactoring: refine and improve exceptions
passed to failExternally call
Key: FLINK-14103
URL: https://issues.apache.org/jira/browse/FLINK-14103
Project: Flink
Issue Type: Improvement
Reporter: Alex
The documentation string for the {{AsynchronousException}} says:
{quote}An exception for wrapping exceptions that are thrown by an operator in
threads other than the
main compute thread of that operator.
{quote}
But the usage of the exception has diverged from the initial intent. In
particular, some actions that are run in the main task's thread (for example
via mailbox) may throw (or pass) instances of this exception.
Also, some exceptions that are already instances of this class may be wrapped
in this exception again.
It maybe needed to just adjust the documentation string of the exception, or
refine and improve the exceptions passed to the exception handling methods.
--
This message was sent by Atlassian Jira
(v8.3.2#803003)