Till Rohrmann created FLINK-9573: ------------------------------------ Summary: Check for leadership with leader session id Key: FLINK-9573 URL: https://issues.apache.org/jira/browse/FLINK-9573 Project: Flink Issue Type: Improvement Components: Distributed Coordination Affects Versions: 1.5.0, 1.6.0 Reporter: Till Rohrmann Assignee: Till Rohrmann
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. -- This message was sent by Atlassian JIRA (v7.6.3#76005)