[
https://issues.apache.org/jira/browse/FLINK-33086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Panagiotis Garefalakis updated FLINK-33086:
-------------------------------------------
Description:
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.
> 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
> Priority: Major
>
> 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)
