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 11:34:29 GMT
Run the application by removing -local argument

On Wed, Mar 21, 2018, 4:49 PM Jungtaek Lim <kabhwan@gmail.com> wrote:

> Hi Justin,
>
> You seemed to refer document in master branch, which will be released as
> Storm 2.0.0.
> Document for v1.2.1 is here:
> https://github.com/apache/storm/blob/v1.2.1/examples/storm-starter/README.markdown
>
> Hope this helps.
>
> Thanks,
> Jungtaek Lim (HeartSaVioR)
>
> 2018년 3월 21일 (수) 오후 12:42, Justin Coyne <jcoyne@justincoyne.com>님이
작성:
>
>> 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