在风暴群集上提交拓扑时出错

Question

在主管上的风暴群集上部署拓扑时出现以下错误。我无法找出确切的原因，因为主管能够找到拓扑但无法下载代码并执行。

2018-01-02 12:23:42.409 o.a.s.d.supervisor [WARN] There was a connection problem with nimbus. #error {
 :cause Connection refused
 :via
 [{:type java.lang.RuntimeException
   :message org.apache.storm.thrift.transport.TTransportException: java.net.ConnectException: Connection refused
   :at [org.apache.storm.security.auth.TBackoffConnect retryNext TBackoffConnect.java 64]}
  {:type org.apache.storm.thrift.transport.TTransportException
   :message java.net.ConnectException: Connection refused
   :at [org.apache.storm.thrift.transport.TSocket open TSocket.java 226]}
  {:type java.net.ConnectException
   :message Connection refused
   :at [java.net.PlainSocketImpl socketConnect PlainSocketImpl.java -2]}]
 :trace
 [[java.net.PlainSocketImpl socketConnect PlainSocketImpl.java -2]
  [java.net.AbstractPlainSocketImpl doConnect AbstractPlainSocketImpl.java 350]
  [java.net.AbstractPlainSocketImpl connectToAddress AbstractPlainSocketImpl.java 206]
  [java.net.AbstractPlainSocketImpl connect AbstractPlainSocketImpl.java 188]
  [java.net.SocksSocketImpl connect SocksSocketImpl.java 392]
  [java.net.Socket connect Socket.java 589]
  [org.apache.storm.thrift.transport.TSocket open TSocket.java 221]
  [org.apache.storm.thrift.transport.TFramedTransport open TFramedTransport.java 81]
  [org.apache.storm.security.auth.SimpleTransportPlugin connect SimpleTransportPlugin.java 103]
  [org.apache.storm.security.auth.TBackoffConnect doConnectWithRetry TBackoffConnect.java 53]
  [org.apache.storm.security.auth.ThriftClient reconnect ThriftClient.java 99]
  [org.apache.storm.security.auth.ThriftClient <init> ThriftClient.java 69]
  [org.apache.storm.utils.NimbusClient <init> NimbusClient.java 106]
  [org.apache.storm.utils.NimbusClient getConfiguredClientAs NimbusClient.java 78]
  [org.apache.storm.utils.NimbusClient getConfiguredClient NimbusClient.java 41]
  [org.apache.storm.blobstore.NimbusBlobStore prepare NimbusBlobStore.java 268]
  [org.apache.storm.utils.Utils getClientBlobStoreForSupervisor Utils.java 468]
  [org.apache.storm.daemon.supervisor$fn__9394 invoke supervisor.clj 926]
  [clojure.lang.MultiFn invoke MultiFn.java 243]
  [org.apache.storm.daemon.supervisor$mk_synchronize_supervisor$this__9163$fn__9181 invoke supervisor.clj 579]
  [org.apache.storm.daemon.supervisor$mk_synchronize_supervisor$this__9163 invoke supervisor.clj 578]
  [org.apache.storm.event$event_manager$fn__8735 invoke event.clj 40]
  [clojure.lang.AFn run AFn.java 22]
  [java.lang.Thread run Thread.java 745]]}

Answer 1

我添加时它起作用了

storm.local.hostname：“local.ip.value”

to storm.yaml