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) >> >>
