You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Lijie Wang (Jira)" <ji...@apache.org> on 2022/12/01 08:56:00 UTC

[jira] [Closed] (FLINK-29364) Root cause of Exceptions thrown in the SourceReader start() method gets "swallowed".

     [ https://issues.apache.org/jira/browse/FLINK-29364?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Lijie Wang closed FLINK-29364.
------------------------------
    Resolution: Not A Problem

> Root cause of Exceptions thrown in the SourceReader start() method gets "swallowed".
> ------------------------------------------------------------------------------------
>
>                 Key: FLINK-29364
>                 URL: https://issues.apache.org/jira/browse/FLINK-29364
>             Project: Flink
>          Issue Type: Bug
>          Components: Runtime / Task
>    Affects Versions: 1.15.3
>            Reporter: Alexander Fedulov
>            Priority: Major
>
> If an exception is thrown in the {_}SourceReader{_}'s _start()_ method, its root cause does not get captured.
> The details are still available here: [Task.java#L758|https://github.com/apache/flink/blob/bccecc23067eb7f18e20bade814be73393401be5/flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java#L758]
> But the execution falls through to [Task.java#L780|https://github.com/apache/flink/blob/bccecc23067eb7f18e20bade814be73393401be5/flink-runtime/src/main/java/org/apache/flink/runtime/taskmanager/Task.java#L780]  and discards the root cause of
> canceling the source invokable without recording the actual reason.
>  
> Hot to reproduce: [DataGeneratorSourceITCase.java#L117|https://github.com/afedulov/flink/blob/3df7669fcc6ba08c5147195b80cc97ac1481ec8c/flink-tests/src/test/java/org/apache/flink/api/connector/source/lib/DataGeneratorSourceITCase.java#L117] 



--
This message was sent by Atlassian Jira
(v8.20.10#820010)