git.net

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

[jira] [Created] (FLINK-9494) Race condition in Dispatcher with concurrent granting and revoking of leaderhship


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)