Matthias Pohl created FLINK-26690: ------------------------------------- Summary: 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 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)