代码之家  ›  专栏  ›  技术社区  ›  Aniruddha

在storm群集上提交拓扑时出错

  •  0
  • Aniruddha  · 技术社区  · 6 年前

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

    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]]}
    
    1 回复  |  直到 6 年前
        1
  •  0
  •   Aniruddha    6 年前

    当我添加

    暴风雨地方的主机名: “本地ip值”

    风暴。亚马尔