Details
-
Bug
-
Status: Closed
-
Critical
-
Resolution: Fixed
-
1.5.0
-
None
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.
Attachments
Issue Links
- relates to
-
FLINK-9573 Check for leadership with leader session id
- Closed
- links to