[
https://issues.apache.org/jira/browse/FLINK-4516?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15568233#comment-15568233
]
ASF GitHub Bot commented on FLINK-4516:
---------------------------------------
GitHub user mxm opened a pull request:
https://github.com/apache/flink/pull/2624
[FLINK-4516] update leadership information in ResourceManager
The leadership information remained static for connectedJobMasters. This
updates it to remove stale JobMasters when they lose leadership status.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/mxm/flink flip-6
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/flink/pull/2624.patch
To close this pull request, make a commit to your master/trunk branch
with (at least) the following in the commit message:
This closes #2624
----
commit 27c81eebff42ca74baa682e514509c06cabb55bb
Author: Maximilian Michels <m...@apache.org>
Date: 2016-10-10T15:36:10Z
[FLINK-4516] update leadership information in ResourceManager
The leadership information remained static for connected
JobMasters. This updates it to remove stale JobMasters when they lose
leadership status.
----
> ResourceManager leadership election
> -----------------------------------
>
> Key: FLINK-4516
> URL: https://issues.apache.org/jira/browse/FLINK-4516
> Project: Flink
> Issue Type: Sub-task
> Components: Cluster Management
> Reporter: zhangjing
> Assignee: zhangjing
>
> 1. When a resourceManager is started, it starts the leadership election
> service first and take part in contending for leadership
> 2. Every resourceManager contains a ResourceManagerLeaderContender, when it
> is granted leadership, it will start SlotManager and other main components.
> when it is revoked leadership, it will stop all its components and clear
> everything.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
