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)