Details
-
Improvement
-
Status: Closed
-
Major
-
Resolution: Fixed
-
1.5.0, 1.6.0
-
None
Description
In order to check whether a LeaderContender is still the leader, it is not sufficient to simply provide a LeaderElectionService#hasLeadership(). Instead, we should extend this method to also take the leader session id as a parameter to distinguish between different calls from the same leader contender with different leader session ids.
Attachments
Issue Links
- is related to
-
FLINK-9494 Race condition in Dispatcher with concurrent granting and revoking of leaderhship
- Closed
- links to