storm-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Justin Coyne <digger...@gmail.com>
Subject Re: Nimbus problem when using storm starter.
Date Wed, 21 Mar 2018 10:57:58 GMT
I’m trying to start it locally, for development. It’s my understanding that when doing
that you don’t have to start ZK or Nimbus separately. Is that right?

-Justin

> On Mar 20, 2018, at 11:09 PM, Ajeesh <ajeeshreloaded@gmail.com> wrote:
> 
> 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