[FLINK-22060] Move null handling from ErrorInfo into Task.notifyFinalState

• Type: Bug
• Status: Open
• Priority: Not a Priority
• Resolution: Unresolved
• Affects Version/s: 1.11.3, 1.12.2, 1.13.0
• Component/s: Runtime / Coordination
• Labels: auto-deprioritized-major auto-deprioritized-minor
• Assignee: Unassigned
• Reporter: Matthias Pohl
• Created: 31/Mar/21 06:25
• Updated: 03/Dec/21 22:38

Description

Ideally, we would want to have this null check since a failure should always have a cause. We didn't introduce a null check so far because of FLINK-21376. There is ErrorInfo. createErrorInfoWithNullableCause for handling this. But it feels to be handled in the wrong place. Instead, we should substitute the null value by the FlinkException in Task.notifyFinalState. This way, we make sure that null never ends up in the ExecutionGraph-related code which enables us to make the invariants stricter on our end.

This would serve as a preparation task

Issue Links

• blocks: FLINK-21376 Failed state might not provide failureCause