Alexander Fedulov created FLINK-29364:
-----------------------------------------
Summary: 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.2
Reporter: Alexander Fedulov
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.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
