storm-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Ajeesh <ajeeshreloa...@gmail.com>
Subject Re: Nimbus problem when using storm starter.
Date Wed, 21 Mar 2018 04:09:54 GMT
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)
>
>

Mime
View raw message