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

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Not A Problem
• Affects Version/s: 1.15.3
• Component/s: Runtime / Task
• Assignee: Unassigned
• Reporter: Alexander Fedulov
• Created: 20/Sep/22 17:48
• Updated: 01/Dec/22 08:55
• Resolved: 01/Dec/22 08:55

Description

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

But the execution falls through to Task.java#L780  and discards the root cause of
canceling the source invokable without recording the actual reason.

 

Hot to reproduce: DataGeneratorSourceITCase.java#L117