[ https://issues.apache.org/jira/browse/FLINK-9494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Till Rohrmann closed FLINK-9494. -------------------------------- Resolution: Fixed Fixed via 1.6.0: 7e51b90d909c6feaac6ed48140df00372e95a45c 1.5.1: a9787d7fb616d231007b7c82e2f5f526370eddf8 > 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 > Assignee: Till Rohrmann > Priority: Critical > 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)