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