Thanks for your help. removing the -local did the trick. I didn't notice that when switching from master to 1.2.1.
-Justin On Wed, Mar 21, 2018 at 6:34 AM, Ajeesh <[email protected]> wrote: > Run the application by removing -local argument > > On Wed, Mar 21, 2018, 4:49 PM Jungtaek Lim <[email protected]> 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 <[email protected]>님이 작성: >> >>> 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) >>> >>>
