You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Matthias Pohl (Jira)" <ji...@apache.org> on 2022/03/16 16:48:00 UTC

[jira] [Created] (FLINK-26690) DefaultJobGraphStore.globalCleanup does not trigger the cleanup when retrying the cleanup after a failover

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)