[ https://issues.apache.org/jira/browse/FLINK-33086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Yangze Guo reassigned FLINK-33086: ---------------------------------- Assignee: Panagiotis Garefalakis > Protect failure enrichment against unhandled exceptions > ------------------------------------------------------- > > Key: FLINK-33086 > URL: https://issues.apache.org/jira/browse/FLINK-33086 > Project: Flink > Issue Type: Sub-task > Components: Runtime / Coordination > Reporter: Panagiotis Garefalakis > Assignee: Panagiotis Garefalakis > Priority: Major > Labels: pull-request-available > > Existing > [labelFailure|https://github.com/apache/flink/blob/603181da811edb47c0d573492639a381fbbedc28/flink-runtime/src/main/java/org/apache/flink/runtime/failure/FailureEnricherUtils.java#L175] > 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. -- This message was sent by Atlassian Jira (v8.20.10#820010)