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)