spark---zookeeper.clientcnxn:服务器为空的会话0x0,意外错误

os8fio9y  于 2021-06-08  发布在  Hbase
关注(0)|答案(1)|浏览(389)

我正在尝试使用以下命令将json加载到hbase

spark-shell --master local[*] --jars ./library/ejml-0.23.jar,library/jollyday.jar,library/protobuf.jar,library/stanford-corenlp-3.6.0-models.jar,library/stanford-english-corenlp-2016-01-10-models.jar,library/stanford-corenlp-3.6.0.jar,library/spark-corenlp-0.1.jar,library/target/scala-2.10/dlrl-library_2.10-1.0.jar,library/json4s.jar --driver-memory 5G -i $FILE_PATH

filepath指向包含解析json和将数据加载到hbase的逻辑的源文件。但是,当Spark壳启动时,它会以以下方式抛出一个连续错误

17/12/27 18:20:17 WARN 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:739)

    at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:350)

    at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1081)

17/12/27 18:20:17 WARN 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:739)

    at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:350)

    at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1081)

请帮我纠正这个问题

cwtwac6a

cwtwac6a1#

听起来你好像还没有开始在你的工作localhost:2181 ... 你是在使用Kafka还是其他以zookeeper为注册中心的框架?

相关问题