Your error is "Missing topology storm code, so can't launch worker with assignment".
One possibility: http://stackoverflow.com/questions/36654714/error-running-topology-in-production-cluster-with-apache-storm-1-0-0-topology-d Or maybe you are still running the topology on localCluster instead of StormSubmitter? On Wed, Jun 1, 2016 at 8:34 PM, Jacob Johansen <[email protected]> wrote: > Hello all, > > I'm receiving the below error on the supervisor and was hoping someone > has seen it before. > > nimbus and zookeeper seem to be functionally correctly. > > 2016-06-01 13:43:53.180 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 > 462] > [org.apache.storm.daemon.supervisor$fn__9317 invoke supervisor.clj 942] > [clojure.lang.MultiFn invoke MultiFn.java 243] > > [org.apache.storm.daemon.supervisor$mk_synchronize_supervisor$this__9078$fn__9096 > invoke supervisor.clj 582] > [org.apache.storm.daemon.supervisor$mk_synchronize_supervisor$this__9078 > invoke supervisor.clj 581] > [org.apache.storm.event$event_manager$fn__8630 invoke event.clj 40] > [clojure.lang.AFn run AFn.java 22] > [java.lang.Thread run Thread.java 745]]} > 2016-06-01 13:43:53.180 o.a.s.d.supervisor [INFO] Finished downloading > code for storm id Topology-1-1464756639 > 2016-06-01 13:43:53.182 o.a.s.d.supervisor [INFO] Missing topology > storm code, so can't launch worker with assignment {:storm-id > "Topology-1-1464756639", :executors [[8 8] [12 12] [2 2] [7 7] [22 22] > [3 3] [24 24] [1 1] [18 18] [6 6] [20 20] [9 9] [23 23] [11 11] [16 > 16] [13 13] [19 19] [21 21] [5 5] [26 26] [10 10] [14 14] [4 4] [15 > 15] [25 25] [17 17]], :resources > #object[org.apache.storm.generated.WorkerResources 0x3a5fc40f > "WorkerResources(mem_on_heap:0.0, mem_off_heap:0.0, cpu:0.0)"]} for > this supervisor 6a5859f1-29d3-4b2e-9426-220b6111b242 on port 6700 with > id 3895364d-ebee-43d4-b96a-3bb4ed0575b6 > > thanks > > Jacob Johansen > -- Regards, Navin
