[ 
https://issues.apache.org/jira/browse/FLINK-6151?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15942598#comment-15942598
 ] 

zhangrucong1982 commented on FLINK-6151:
----------------------------------------

Yes, I agree with you. May be the ZK client curator has this problem.I think 
the other two nodes are still ok,  the ZK client frame curator can connect the 
other two zk server nodes. If one is ok, it may not occur this warn log. Thanks!

> The zookeeper occur a warning when one node of zookeeper server is down
> -----------------------------------------------------------------------
>
>                 Key: FLINK-6151
>                 URL: https://issues.apache.org/jira/browse/FLINK-6151
>             Project: Flink
>          Issue Type: Bug
>          Components: Distributed Coordination
>            Reporter: zhangrucong1982
>
> I use the flink in yarn cluster of version 1.2.0.  The HA is configured in 
> flink-conf.yaml.The configurations are :
> high-availability: zookeeper
> high-availability.zookeeper.quorum: 
> 100.106.40.102:2181,100.106.57.136:2181,100.106.41.233:2181
> high-availability.zookeeper.storageDir: hdfs:/flink
> high-availability.zookeeper.client.acl: open
> high-availability.zookeeper.path.root:  flink0308
> zookeeper.sasl.disable: true
> The ZK version is 3.5.1.When one of ZK server node is down, the Flink 
> client、JM、TM occur a following warning:
> 2017-03-22 10:14:06,196 INFO  org.apache.zookeeper.ClientCnxn                 
>               - Opening socket connection to server 
> 100.106.57.136/100.106.57.136:2181
> 2017-03-22 10:14:06,196 INFO  org.apache.zookeeper.ClientCnxn                 
>               - Opening socket connection to server 
> 100.106.57.136/100.106.57.136:2181
> 2017-03-22 10:14:06,197 WARN  org.apache.zookeeper.ClientCnxn                 
>               - Session 0x0 for server null, unexpected error, closing socket 
> connection and attempting reconnect
> java.net.ConnectException: Connection refused
>         at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
>         at 
> sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:717)
>         at 
> org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:364)
>         at 
> org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1426)
> It seems the message is sent to the ZK server before the session is 
> established.



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

Reply via email to