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)

Reply via email to