Till Rohrmann created FLINK-9494:
------------------------------------

             Summary: Race condition in Dispatcher with concurrent granting and 
revoking of leaderhship
                 Key: FLINK-9494
                 URL: https://issues.apache.org/jira/browse/FLINK-9494
             Project: Flink
          Issue Type: Bug
          Components: Distributed Coordination
    Affects Versions: 1.5.0
            Reporter: Till Rohrmann
             Fix For: 1.6.0, 1.5.1


The {{Dispatcher}} contains a race condition when an instance is granted 
leadership and then quickly afterwards gets the leadership revoked. The problem 
is that we don't check in the recovered jobs future callback that we still have 
the leadership. This can lead to a corrupted state of the {{Dispatcher}}.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)

Reply via email to