【问题标题】:Storm UI getting Internal Server Error :org.apache.thrift7.transport.TTransportException: java.net.ConnectException: Connection refusedStorm UI 获取内部服务器错误:org.apache.thrift7.transport.TTransportException:java.net.ConnectException:连接被拒绝
【发布时间】:2014-08-20 18:41:58
【问题描述】:

当我尝试连接到 Storm ui 时,网络向我显示了这一点

org.apache.thrift7.transport.TTransportException: java.net.ConnectException: Connection refused
    at org.apache.thrift7.transport.TSocket.open(TSocket.java:183)
    at org.apache.thrift7.transport.TFramedTransport.open(TFramedTransport.java:81)
    at backtype.storm.thrift$nimbus_client_and_conn.invoke(thrift.clj:75)
    at backtype.storm.ui.core$all_topologies_summary.invoke(core.clj:493)
    at backtype.storm.ui.core$fn__8227.invoke(core.clj:793)
    at compojure.core$make_route$fn__3365.invoke(core.clj:93)
    at compojure.core$if_route$fn__3353.invoke(core.clj:39)
    at compojure.core$if_method$fn__3346.invoke(core.clj:24)
    at compojure.core$routing$fn__3371.invoke(core.clj:106)
    at clojure.core$some.invoke(core.clj:2443)
    at compojure.core$routing.doInvoke(core.clj:106)
    at clojure.lang.RestFn.applyTo(RestFn.java:139)
    at clojure.core$apply.invoke(core.clj:619)
    at compojure.core$routes$fn__3375.invoke(core.clj:111)

Zookeeper 也启动了,并且连接 zookeeper 在storm.ymal 等风暴中连接

storm.zookeeper.servers:
    - "localhost"

这是怎么引起的,我该如何解决?

【问题讨论】:

  • Zookeeper 的默认端口是 2181。你检查它是开放的吗?
  • 听起来你已经安装了包zookeeper,但不是zookeeperd
  • 我遇到了同样的问题。我把这个属性设置错了。 storm.local.dir:

标签: apache-zookeeper apache-storm


【解决方案1】:

nimbus.host 怎么样,它是从默认的nimbus 设置为真正的主机吗?

  1 ########### These MUST be filled in for a storm configuration                                                                                                               
  2  storm.zookeeper.servers:                                                                           
  3      - "localhost"                                                                                  
  4 #                                                                                                   
  5  nimbus.host: "localhost"                                                                           
  6 #                                                                                                   
  7 #                                                                                                   
  8 # ##### These may optionally be filled in:                                                          
  9 #                                                                                                   
 10 ## List of custom serializations                                                                    
 11 # topology.kryo.register:                                                                           
 12 #     - org.mycompany.MyType                                                                        
 13 #     - org.mycompany.MyType2: org.mycompany.MyType2Serializer                                      
 14 #                                                                                                   
 15 ## List of custom kryo decorators                                                                   
 16 # topology.kryo.decorators:                                                                         
 17 #     - org.mycompany.MyDecorator                                                                   
 18 #                                                                                                   
 19 ## Locations of the drpc servers                                                                    
 20 # drpc.servers:                                                                                     
 21 #     - "server1"                                                                                   
 22 #     - "server2" 

【讨论】:

    猜你喜欢
    • 1970-01-01
    • 2017-01-04
    • 2014-11-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 2017-04-28
    • 2020-08-07
    相关资源
    最近更新 更多