在 Nimbus 中提交拓扑时出错

Question

提交拓扑时出现的错误

java.net.ConnectException: Connection refused
at backtype.storm.utils.NimbusClient.<init>(NimbusClient.java:36)
at backtype.storm.utils.NimbusClient.getConfiguredClient(NimbusClient.java:17)

这是我在 nimbus 日志文件中得到的

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 文件

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"

还有什么吗？？！我这里有什么问题？

Answer 1

问题出在光轮的大小上应该越大越好

喜欢

nimbus.thrift.max_buffer_size: 20480000

在 Nimbus 中提交拓扑时出错

Error when submit topology in Nimbus

apache-storm

apache-zookeeper