我用spark1.5.2配置ha,用的是zookeeper3.4.8的版本,安装官网的文档配置如下:
export SPARK_DAEMON_JAVA_OPTS="-Dspark.deploy.recoveryMode=ZOOKEEPER -Dspark.deploy.zookeeper.url=hadoopspark01:2181,hadoopspark02:2181,hadoopspark03:2181,hadoopspark04:2181,hadoopspark05:218
1 -Dspark.deploy.zookeeper.dir=/spark"
spark集群启动正常,可以做主备切换时,所有的worker进程都挂了,备用的master节点可以切换成功。
zookeeper会报如下:
2016-05-17 14:31:47,987 [myid:3] - WARN [NIOServerCxn.Factory:0.0.0.0/0.0.0.0:2181:NIOServerCnxn@357] - caught end of stream exception
EndOfStreamException: Unable to read additional data from client sessionid 0x354bc71124d0005, likely client has closed socket
at org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:230)
at org.apache.zookeeper.server.NIOServerCnxnFactory.run(NIOServerCnxnFactory.java:203)
at java.lang.Thread.run(Thread.java:745)
请大神帮忙看看,是什么原因?
|