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

• Type: Bug
• Status: Closed
• Priority: Critical
• Resolution: Fixed
• Affects Version/s: 1.5.0
• Fix Version/s: 1.5.1, 1.6.0
• Component/s: Runtime / Coordination
• Assignee: Till Rohrmann
• Reporter: Till Rohrmann
• Created: 01/Jun/18 13:42
• Updated: 14/Jun/18 16:10
• Resolved: 14/Jun/18 16:09

Description

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.

Issue Links

• relates to: FLINK-9573 Check for leadership with leader session id
• links to: GitHub Pull Request #6155