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)