[FLINK-33086] Protect failure enrichment against unhandled exceptions

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.18.0
• Component/s: Runtime / Coordination
• Labels: pull-request-available
• Assignee: Panagiotis Garefalakis
• Reporter: Panagiotis Garefalakis
• Created: 14/Sep/23 01:50
• Updated: 14/Sep/23 15:32
• Resolved: 14/Sep/23 15:32

Description

Existing labelFailure async logic is expecting FailureEnricher future to never fail (or do their own exception handling) however there is no way to enforce that as they are loaded as they are implemented as pluggable components. This could result to throwing away labels from other enrichers that successfully completed. 

A better solution would be to handle the failures and LOG the errors.

Issue Links

• links to: GitHub Pull Request #23413