Mailing-List: contact dev-help@curator.incubator.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@curator.incubator.apache.org
Date: Mon, 29 Jul 2013 17:37:48 +0000 (UTC)
From: "Jordan Zimmerman (JIRA)" <jira@apache.org>
To: dev@curator.incubator.apache.org
Message-ID: <JIRA.12660320.1375075136809.129866.1375119468827@arcas>
In-Reply-To: <JIRA.12660320.1375075136809@arcas>
References: <JIRA.12660320.1375075136809@arcas>
Subject: [jira] [Reopened] (CURATOR-49) LeaderSelector has no response when
 delete the leader node by other clients
MIME-Version: 1.0
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: 7bit


     [ https://issues.apache.org/jira/browse/CURATOR-49?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Jordan Zimmerman reopened CURATOR-49:
-------------------------------------


Or, are you trying to test something? Please give more details.
                
> LeaderSelector has no response when delete the leader node by other clients
> ---------------------------------------------------------------------------
>
>                 Key: CURATOR-49
>                 URL: https://issues.apache.org/jira/browse/CURATOR-49
>             Project: Apache Curator
>          Issue Type: Bug
>          Components: Recipes
>    Affects Versions: 2.1.0-incubating
>         Environment: curator-recipes 2.1.0-incubating and  zookeeper 3.4.5
>            Reporter: Ding Jinqiang
>
> If I setup a normal LeaderSelection with two participants, and as expected one of them becomes the leader. But when I delete the leader node manually by other clients, the other leaderSelector becomes the leader normally. But the leaderSelector, which is the previous leader, does not receive any notification in the LeaderSelectorListener. 
> Well, my question is, is this normal, or I just missed something? 
> Sample code may like this:
> 		RetryPolicy retryPolicy = new ExponentialBackoffRetry(1000, 1);
> 		client = CuratorFrameworkFactory.newClient(Config.getInstance().getServerConnectString(),
> 				retryPolicy);
> 		client.start();
>  		LeaderSelectorListener listener = new LeaderSelectorListener() {
> 			@Override
> 			public void takeLeadership(CuratorFramework client) throws Exception {
> 				logger.info("takeLeadership, thread id:"+Thread.currentThread().getId());
>  				Thread.sleep(Long.MAX_VALUE);
> 			}
> 			@Override
> 			public void stateChanged(CuratorFramework client, ConnectionState newState) {
> 				logger.info("Zookeeper connection stateChanged, new state is " + newState);
> 			}
> 		};
> 		selector = new LeaderSelector(client, Config.getInstance().getEclectPath());
> 		selector.autoRequeue();
> 		selector.start();
>  

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira