[
https://issues.apache.org/jira/browse/FLINK-26690?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl updated FLINK-26690:
----------------------------------
Description: The {{DefaultJobGraphStore}} does not get the JobGraph of a
dirty globally-terminated job after failover anymore because the job is not
going to be recovered. The globalCleanup checks the addedJobs still, which is
not necessary but prevents the cleanup in that case. (was: The
`DefaultJobGraphStore` does not get the JobGraph of a dirty globally-terminated
job after failover anymore because the job is not going to be recovered. The
globalCleanup checks the addedJobs still, which is not necessary but prevents
the cleanup in that case.)
> DefaultJobGraphStore.globalCleanup does not trigger the cleanup when retrying
> the cleanup after a failover
> ----------------------------------------------------------------------------------------------------------
>
> Key: FLINK-26690
> URL: https://issues.apache.org/jira/browse/FLINK-26690
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Coordination
> Affects Versions: 1.15.0, 1.16.0
> Reporter: Matthias Pohl
> Assignee: Matthias Pohl
> Priority: Blocker
> Fix For: 1.15.0
>
>
> The {{DefaultJobGraphStore}} does not get the JobGraph of a dirty
> globally-terminated job after failover anymore because the job is not going
> to be recovered. The globalCleanup checks the addedJobs still, which is not
> necessary but prevents the cleanup in that case.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
