You have an exception like "connection refused", this is causing the issue while trying to connect with nimbus host. Can you try to ping to the nimbus machine from the machine where you are trying to start the topology? 

On Wed, Mar 21, 2018, 9:12 AM Justin Coyne <jcoyne@justincoyne.com> wrote:
I'm a newbie to Storm. I've installed 1.2.1 and I'm attempting to run the example in examples/storm-starter/.

Per the Readme I've run this command:

storm jar target/storm-starter-1.2.1.jar org.apache.storm.starter.ExclamationTopology -local

and I get the stacktrace that I've included below.  Does anyone know what I'm doing wrong?

Thanks for your time and understanding.

Regards,
Justin


592  [main] INFO  o.a.s.StormSubmitter - Generated ZooKeeper secret payload for MD5-digest: -8892471762429528710:-7128252511602900296
672  [main] WARN  o.a.s.u.StormBoundedExponentialBackoffRetry - WILL SLEEP FOR 2001ms (NOT MAX)
2676 [main] WARN  o.a.s.u.StormBoundedExponentialBackoffRetry - WILL SLEEP FOR 2003ms (NOT MAX)
4683 [main] WARN  o.a.s.u.StormBoundedExponentialBackoffRetry - WILL SLEEP FOR 2007ms (NOT MAX)
6696 [main] WARN  o.a.s.u.StormBoundedExponentialBackoffRetry - WILL SLEEP FOR 2011ms (NOT MAX)
8709 [main] WARN  o.a.s.u.StormBoundedExponentialBackoffRetry - WILL SLEEP FOR 2018ms (NOT MAX)
10731 [main] WARN  o.a.s.u.NimbusClient - Ignoring exception while trying to get leader nimbus info from localhost. will retry with a different seed host.
java.lang.RuntimeException: java.lang.RuntimeException: org.apache.storm.thrift.transport.TTransportException: java.net.ConnectException: Connection refused
    at org.apache.storm.security.auth.ThriftClient.reconnect(ThriftClient.java:112) ~[storm-core-1.2.1.jar:1.2.1]
    at org.apache.storm.security.auth.ThriftClient.<init>(ThriftClient.java:73) ~[storm-core-1.2.1.jar:1.2.1]
    at org.apache.storm.utils.NimbusClient.<init>(NimbusClient.java:136) ~[storm-core-1.2.1.jar:1.2.1]
    at org.apache.storm.utils.NimbusClient.getConfiguredClientAs(NimbusClient.java:92) [storm-core-1.2.1.jar:1.2.1]
    at org.apache.storm.utils.NimbusClient.getConfiguredClientAs(NimbusClient.java:66) [storm-core-1.2.1.jar:1.2.1]
    at org.apache.storm.utils.NimbusClient.getConfiguredClient(NimbusClient.java:58) [storm-core-1.2.1.jar:1.2.1]
    at org.apache.storm.blobstore.NimbusBlobStore.prepare(NimbusBlobStore.java:268) [storm-core-1.2.1.jar:1.2.1]
    at org.apache.storm.StormSubmitter.getListOfKeysFromBlobStore(StormSubmitter.java:595) [storm-core-1.2.1.jar:1.2.1]
    at org.apache.storm.StormSubmitter.validateConfs(StormSubmitter.java:561) [storm-core-1.2.1.jar:1.2.1]
    at org.apache.storm.StormSubmitter.submitTopologyAs(StormSubmitter.java:207) [storm-core-1.2.1.jar:1.2.1]
    at org.apache.storm.StormSubmitter.submitTopology(StormSubmitter.java:387) [storm-core-1.2.1.jar:1.2.1]
    at org.apache.storm.StormSubmitter.submitTopologyWithProgressBar(StormSubmitter.java:423) [storm-core-1.2.1.jar:1.2.1]
    at org.apache.storm.StormSubmitter.submitTopologyWithProgressBar(StormSubmitter.java:404) [storm-core-1.2.1.jar:1.2.1]
    at org.apache.storm.starter.ExclamationTopology.main(ExclamationTopology.java:76) [storm-starter-1.2.1.jar:1.2.1]
Caused by: java.lang.RuntimeException: org.apache.storm.thrift.transport.TTransportException: java.net.ConnectException: Connection refused
    at org.apache.storm.security.auth.TBackoffConnect.retryNext(TBackoffConnect.java:64) ~[storm-core-1.2.1.jar:1.2.1]
    at org.apache.storm.security.auth.TBackoffConnect.doConnectWithRetry(TBackoffConnect.java:56) ~[storm-core-1.2.1.jar:1.2.1]
    at org.apache.storm.security.auth.ThriftClient.reconnect(ThriftClient.java:104) ~[storm-core-1.2.1.jar:1.2.1]
    ... 13 more
Caused by: org.apache.storm.thrift.transport.TTransportException: java.net.ConnectException: Connection refused
    at org.apache.storm.thrift.transport.TSocket.open(TSocket.java:226) ~[storm-core-1.2.1.jar:1.2.1]
    at org.apache.storm.thrift.transport.TFramedTransport.open(TFramedTransport.java:81) ~[storm-core-1.2.1.jar:1.2.1]
    at org.apache.storm.security.auth.SimpleTransportPlugin.connect(SimpleTransportPlugin.java:105) ~[storm-core-1.2.1.jar:1.2.1]
    at org.apache.storm.security.auth.TBackoffConnect.doConnectWithRetry(TBackoffConnect.java:53) ~[storm-core-1.2.1.jar:1.2.1]
    at org.apache.storm.security.auth.ThriftClient.reconnect(ThriftClient.java:104) ~[storm-core-1.2.1.jar:1.2.1]
    ... 13 more
Caused by: java.net.ConnectException: Connection refused
    at java.net.PlainSocketImpl.socketConnect(Native Method) ~[?:1.8.0_77]
    at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350) ~[?:1.8.0_77]
    at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206) ~[?:1.8.0_77]
    at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188) ~[?:1.8.0_77]
    at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392) ~[?:1.8.0_77]
    at java.net.Socket.connect(Socket.java:589) ~[?:1.8.0_77]
    at org.apache.storm.thrift.transport.TSocket.open(TSocket.java:221) ~[storm-core-1.2.1.jar:1.2.1]
    at org.apache.storm.thrift.transport.TFramedTransport.open(TFramedTransport.java:81) ~[storm-core-1.2.1.jar:1.2.1]
    at org.apache.storm.security.auth.SimpleTransportPlugin.connect(SimpleTransportPlugin.java:105) ~[storm-core-1.2.1.jar:1.2.1]
    at org.apache.storm.security.auth.TBackoffConnect.doConnectWithRetry(TBackoffConnect.java:53) ~[storm-core-1.2.1.jar:1.2.1]
    at org.apache.storm.security.auth.ThriftClient.reconnect(ThriftClient.java:104) ~[storm-core-1.2.1.jar:1.2.1]
    ... 13 more
Exception in thread "main" org.apache.storm.utils.NimbusLeaderNotFoundException: Could not find leader nimbus from seed hosts [localhost]. Did you specify a valid list of nimbus hosts for config nimbus.seeds?
    at org.apache.storm.utils.NimbusClient.getConfiguredClientAs(NimbusClient.java:120)
    at org.apache.storm.utils.NimbusClient.getConfiguredClientAs(NimbusClient.java:66)
    at org.apache.storm.utils.NimbusClient.getConfiguredClient(NimbusClient.java:58)
    at org.apache.storm.blobstore.NimbusBlobStore.prepare(NimbusBlobStore.java:268)
    at org.apache.storm.StormSubmitter.getListOfKeysFromBlobStore(StormSubmitter.java:595)
    at org.apache.storm.StormSubmitter.validateConfs(StormSubmitter.java:561)
    at org.apache.storm.StormSubmitter.submitTopologyAs(StormSubmitter.java:207)
    at org.apache.storm.StormSubmitter.submitTopology(StormSubmitter.java:387)
    at org.apache.storm.StormSubmitter.submitTopologyWithProgressBar(StormSubmitter.java:423)
    at org.apache.storm.StormSubmitter.submitTopologyWithProgressBar(StormSubmitter.java:404)
    at org.apache.storm.starter.ExclamationTopology.main(ExclamationTopology.java:76)