[ 
https://issues.apache.org/jira/browse/FLINK-27053?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17520338#comment-17520338
 ] 

Matthias Pohl commented on FLINK-27053:
---------------------------------------

Hi [~Zsigner], the issue here is that we want to integrate the cleanup of 
checkpoints into the retry loop of the Dispatcher job cleanup. That would 
require errors to be propagated through exceptions instead of swallowing them 
and printing some log message.

> IncrementalRemoteKeyedStateHandle.discardState swallows errors
> --------------------------------------------------------------
>
>                 Key: FLINK-27053
>                 URL: https://issues.apache.org/jira/browse/FLINK-27053
>             Project: Flink
>          Issue Type: Sub-task
>          Components: Runtime / Coordination
>            Reporter: Matthias Pohl
>            Priority: Major
>
> IncrementalRemoteKeyedStateHandle.discardState swallows errors instead of 
> propagating them which would make the discard failure go un-noticed.



--
This message was sent by Atlassian Jira
(v8.20.1#820001)

Reply via email to