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)

Reply via email to