Home | About | Sematext search-lucene.com search-hadoop.com
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB
 Search Hadoop and all its subprojects:

Switch to Threaded View
Zookeeper >> mail # user >> ZooKeeper question


Copy link to this message
-
Re: ZooKeeper question
On Wed, May 30, 2012 at 2:21 PM, Bogdan Odobas <[EMAIL PROTECTED]> wrote:
>
> Hi and thank you for help with this issue:
> I have this piece of code:
> @Overridepublic void process(WatchedEvent event) {               if(Event.KeeperState.Disconnected == event.getState()){//      Client is not connected to any server in the ensemble   System.err.println(">>>Disconnected<<<");       System.err.println( zk.getState());...//    Here I have code that async waits for a bit then closes the ZK if it cannot reconnect after a few attempts, because I only need ZK to read some configuration. If not available, the config is read from a property file. I don't want to try and keep reconnecting//start a new thread//in this thread, check if  zk.getState() is not connected still.//if still not connected, wait for 10 seconds//if notified, means connected//if the wait() time is up, it means not connected still. Close ZK}
> The System.err.println( zk.getState()); prints "CONNECTED"
> In other words, I get a disconnected event, but the ZK shows connected. So when the run() method of the thread is entered, the first statement (if ( zk.getState()!= closed))  returns true and it skips the rest.
> Why ZK state is connected if I just got notified about a disconnect? Can I do something to flush the state?
> Thanks...

I'm having trouble making heads/tails of this because of the
formatting, could you fix the formatting? Or perhaps use gist (etc..)
to post.

Regards,

Patrick
NEW: Monitor These Apps!
elasticsearch, apache solr, apache hbase, hadoop, redis, casssandra, amazon cloudwatch, mysql, memcached, apache kafka, apache zookeeper, apache storm, ubuntu, centOS, red hat, debian, puppet labs, java, senseiDB