[
https://issues.apache.org/jira/browse/FLINK-32422?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias Pohl reassigned FLINK-32422:
-------------------------------------
Assignee: Matthias Pohl
> EmbeddedLeaderService doesn't handle the leader events properly in edge cases
> -----------------------------------------------------------------------------
>
> Key: FLINK-32422
> URL: https://issues.apache.org/jira/browse/FLINK-32422
> Project: Flink
> Issue Type: Sub-task
> Components: Runtime / Coordination
> Affects Versions: 1.18.0
> Reporter: Matthias Pohl
> Assignee: Matthias Pohl
> Priority: Minor
> Labels: pull-request-available
>
> The leadership is granted when registering the first contender. This sets the
> leadership flag within the EmbeddedLeaderService (see
> [EmbeddedLeaderService:312ff|https://github.com/apache/flink/blob/033aca7566a0a561410b3c0e1ae8dca856cd26ce/flink-runtime/src/main/java/org/apache/flink/runtime/highavailability/nonha/embedded/EmbeddedLeaderService.java#L312]:
> the grantLeadershipCall is triggered afterwards informing the contender
> about its leadership). In the meantime, close can be called on the contender
> which deregisters the contender again calling revoke on the contender without
> having been able to gain the leadership.
> This issue was introduced by FLINK-30765.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
