本文介绍了在 Nimbus 中提交拓扑时出错的处理方法，对大家解决问题具有一定的参考价值，需要的朋友们下面随着小编来一起学习吧！
问题描述
提交拓扑时的错误
java.net.ConnectException: Connection refused
at backtype.storm.utils.NimbusClient.<init>(NimbusClient.java:36)
at backtype.storm.utils.NimbusClient.getConfiguredClient(NimbusClient.java:17)
这是我在 nimbus 日志文件中得到的
This what i got in nimbus log file
2015-09-22 04:19:58 ClientCnxn [INFO] Socket connection established to
localhost/127.0.0.1:2181, initiating session
2015-09-22 04:20:13 ConnectionState [ERROR] Connection timed out
org.apache.zookeeper.KeeperException$ConnectionLossException:
KeeperErrorCode = ConnectionLoss
at com.netflix.curator.ConnectionState.getZooKeeper(ConnectionState.java:72)
at com.netflix.curator.CuratorZookeeperClient.getZooKeeper(CuratorZookeeperClient.java:74)
这里是我的storm.yaml文件
and here my storm.yaml file
storm.zookeeper.servers:
- "127.0.0.1"
nimbus.host: "127.0.0.1"
storm.local.dir: /tmp/storm
drpc.servers:
- "127.0.0.1"
- "server2"
还有什么吗??！我这里有什么问题?
is there anything else ??! what's wrong i have here ?
推荐答案
问题出在 nimbus 的大小上应该越大越好
The problem was in the size of nimbus it should be greater as possible
喜欢
nimbus.thrift.max_buffer_size: 20480000
这篇关于在 Nimbus 中提交拓扑时出错的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持！