[jira] [Created] (FLINK-14103) StreamTask refactoring: refine and improve exceptions passed to failExternally call

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-14103) StreamTask refactoring: refine and improve exceptions passed to failExternally call

Shang Yuanchun (Jira)
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)