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

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

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

Shang Yuanchun (Jira)
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)