airavata-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Lahiru Ginnaliya Gamathige <glah...@gmail.com>
Subject Fwd: Intermittent connection loss error
Date Wed, 22 Apr 2015 04:59:40 GMT
---------- Forwarded message ----------
From: <indirapriyadharshini.thangamani@wipro.com>
Date: Wed, Apr 22, 2015 at 12:51 AM
Subject: Re: Intermittent connection loss error
To: user@zookeeper.apache.org


Hi Lahiru Ginnaliya Gamathige,

Once in a while there may be a time change caused by NTP which causes all
zookeeper client sessions to close. This may be the reason. Pls refer
https://issues.apache.org/jira/browse/ZOOKEEPER-1366. (But this has been
fixed in 3.5.1). This may help you.

Regards,
Indira Priyadharshini
______________________________________
From: Lahiru Ginnaliya Gamathige <glahiru@gmail.com>
Sent: Tuesday, April 21, 2015 8:13 PM
To: user@zookeeper.apache.org
Subject: Intermittent connection loss error

Hi Devs,

We are using ZK in Apache Airavata and when we run it for sometime some
connections are get lost and never get reconnect. I get following error and
since I try to reconnect in my process method it keeps trying and exhaust
the log. Of course I can fix the log issue but I am not sure why this is
happening . I am using ZK in standalone mode just single instance and below
is the code I use to reconnect and the log.

2015-04-08 09:43:10,785 [main-SendThread(gw111.iu.xsede.org:2181)] WARN
org.apache.zookeeper.ClientCnxn - Session 0x0 for server
gw111.iu.xsede.org/149.165.228.109:2181, unexpected error, closing socket
connection and attempting reconnect
java.io.IOException: Connection reset by peer
at sun.nio.ch.FileDispatcherImpl.read0(Native Method)
at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:39)
at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:223)
at sun.nio.ch.IOUtil.read(IOUtil.java:192)
at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:380)
at
org.apache.zookeeper.ClientCnxnSocketNIO.doIO(ClientCnxnSocketNIO.java:66)
at
org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:291)
at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1041)


@Override
synchronized public void process(WatchedEvent watchedEvent) {
    logger.info(watchedEvent.getPath());
    synchronized (mutex) {
        Event.KeeperState state = watchedEvent.getState();
        logger.info(state.name());
        switch(state){
            case SyncConnected:
                mutex.notify();
            case Expired:case Disconnected:
                try {
                    mutex = -1;
                    zk = new
ZooKeeper(AiravataZKUtils.getZKhostPort(),
AiravataZKUtils.getZKTimeout(), this);
                    synchronized (mutex) {
                        mutex.wait();  // waiting for the syncConnected
event
                    }
                    storeServerConfig();
                } catch (IOException e) {
                    logger.error("Error while synchronizing with
zookeeper", e);
                } catch (ApplicationSettingsException e) {
                    logger.error("Error while synchronizing with
zookeeper", e);
                } catch (InterruptedException e) {
                    logger.error("Error while synchronizing with
zookeeper", e);
                } catch (AiravataSystemException e) {
                    logger.error("Error while synchronizing with
zookeeper", e);
                }
        }
    }
}


Lahiru


--
Research Assistant
Science Gateways Group
Indiana University
The information contained in this electronic message and any attachments to
this message are intended for the exclusive use of the addressee(s) and may
contain proprietary, confidential or privileged information. If you are not
the intended recipient, you should not disseminate, distribute or copy this
e-mail. Please notify the sender immediately and destroy all copies of this
message and any attachments. WARNING: Computer viruses can be transmitted
via email. The recipient should check this email and any attachments for
the presence of viruses. The company accepts no liability for any damage
caused by any virus transmitted by this email. www.wipro.com



-- 
Research Assistant
Science Gateways Group
Indiana University

Mime
View raw message