Ignore the last part. There was a permission problem on local.dir, no idea how ownership changed on that... weird.
On Mon, May 2, 2016 at 2:33 AM, Joaquin Menchaca <[email protected]> wrote: > I was doing originally: > > $ storm jar storm-starter-0.10.0.jar storm.starter.ExclamationTopology > > But finding some docs on HortonNetworks, I ran it with a parameter, > which it uses to register a topology name, I guess: > > $ storm jar /vagrant/topologies/storm-starter-0.10.0.jar > storm.starter.ExclamationTopology Exclamation > > This worked in my on one cluster (using vagrant), but when I did the > same command on AWS (both Ubuntu 14), my results are different: > > $ storm jar storm-starter-0.10.0.jar storm.starter.ExclamationTopology > Exclamation > Running: /usr/lib/jvm/java-8-oracle/bin/java -client -Ddaemon.name= > -Dstorm.options= -Dstorm.home=/usr/lib/apache/storm/0.10.0 > -Dstorm.log.dir=/usr/lib/apache/storm/0.10.0/logs > -Djava.library.path=/usr/local/lib:/opt/local/lib:/usr/lib > -Dstorm.conf.file= -cp > /usr/lib/apache/storm/0.10.0/lib/reflectasm-1.07-shaded.jar:/usr/lib/apache/storm/0.10.0/lib/kryo-2.21.jar:/usr/lib/apache/storm/0.10.0/lib/log4j-api-2.1.jar:/usr/lib/apache/storm/0.10.0/lib/clojure-1.6.0.jar:/usr/lib/apache/storm/0.10.0/lib/slf4j-api-1.7.7.jar:/usr/lib/apache/storm/0.10.0/lib/log4j-slf4j-impl-2.1.jar:/usr/lib/apache/storm/0.10.0/lib/minlog-1.2.jar:/usr/lib/apache/storm/0.10.0/lib/asm-4.0.jar:/usr/lib/apache/storm/0.10.0/lib/hadoop-auth-2.4.0.jar:/usr/lib/apache/storm/0.10.0/lib/log4j-core-2.1.jar:/usr/lib/apache/storm/0.10.0/lib/servlet-api-2.5.jar:/usr/lib/apache/storm/0.10.0/lib/storm-core-0.10.0.jar:/usr/lib/apache/storm/0.10.0/lib/log4j-over-slf4j-1.6.6.jar:/usr/lib/apache/storm/0.10.0/lib/disruptor-2.10.4.jar:storm-starter-0.10.0.jar:/usr/lib/apache/storm/0.10.0/conf:/usr/lib/apache/storm/0.10.0/bin > -Dstorm.jar=storm-starter-0.10.0.jar storm.starter.ExclamationTopology > Exclamation > 726 [main] INFO b.s.u.Utils - Using defaults.yaml from resources > 848 [main] INFO b.s.u.Utils - Using storm.yaml from resources > 919 [main] INFO b.s.u.Utils - Using defaults.yaml from resources > 940 [main] INFO b.s.u.Utils - Using storm.yaml from resources > 948 [main] INFO b.s.StormSubmitter - Generated ZooKeeper secret > payload for MD5-digest: -6434592996563726871:-7362939470144077130 > 950 [main] INFO b.s.s.a.AuthUtils - Got AutoCreds [] > 965 [main] INFO b.s.u.StormBoundedExponentialBackoffRetry - The > baseSleepTimeMs [2000] the maxSleepTimeMs [60000] the maxRetries [5] > 994 [main] INFO b.s.u.StormBoundedExponentialBackoffRetry - The > baseSleepTimeMs [2000] the maxSleepTimeMs [60000] the maxRetries [5] > 1017 [main] INFO b.s.u.StormBoundedExponentialBackoffRetry - The > baseSleepTimeMs [2000] the maxSleepTimeMs [60000] the maxRetries [5] > Exception in thread "main" java.lang.RuntimeException: > org.apache.thrift7.transport.TTransportException > at backtype.storm.StormSubmitter.submitJarAs(StormSubmitter.java:399) > at backtype.storm.StormSubmitter.submitTopologyAs(StormSubmitter.java:229) > at backtype.storm.StormSubmitter.submitTopology(StormSubmitter.java:271) > at > backtype.storm.StormSubmitter.submitTopologyWithProgressBar(StormSubmitter.java:307) > at > backtype.storm.StormSubmitter.submitTopologyWithProgressBar(StormSubmitter.java:288) > at storm.starter.ExclamationTopology.main(ExclamationTopology.java:76) > Caused by: org.apache.thrift7.transport.TTransportException > at > org.apache.thrift7.transport.TIOStreamTransport.read(TIOStreamTransport.java:132) > at org.apache.thrift7.transport.TTransport.readAll(TTransport.java:86) > at > org.apache.thrift7.transport.TFramedTransport.readFrame(TFramedTransport.java:129) > at > org.apache.thrift7.transport.TFramedTransport.read(TFramedTransport.java:101) > at org.apache.thrift7.transport.TTransport.readAll(TTransport.java:86) > at > org.apache.thrift7.protocol.TBinaryProtocol.readAll(TBinaryProtocol.java:429) > at > org.apache.thrift7.protocol.TBinaryProtocol.readI32(TBinaryProtocol.java:318) > at > org.apache.thrift7.protocol.TBinaryProtocol.readMessageBegin(TBinaryProtocol.java:219) > at org.apache.thrift7.TServiceClient.receiveBase(TServiceClient.java:69) > at > backtype.storm.generated.Nimbus$Client.recv_beginFileUpload(Nimbus.java:420) > at backtype.storm.generated.Nimbus$Client.beginFileUpload(Nimbus.java:408) > at backtype.storm.StormSubmitter.submitJarAs(StormSubmitter.java:370) > ... 5 more > > On Mon, May 2, 2016 at 2:25 AM, Matthew Lowe <[email protected]> wrote: >> In your topology code, what call are you using to deploy to storm? >> >> Best Regards >> Matthew Lowe >> >>> On 02 May 2016, at 10:43, Joaquin Menchaca <[email protected]> wrote: >>> >>> But I seem to be running topologies only on nimbus. >>> >>> The ui is not showing anything under Topology Summary. It says "No >>> data available in table". >>> >>> It does show three systems in Supervisor Summary. >>> >>> I ran using storm starter topologies: "RollingTopWords", >>> "WordCountTopology", and "ExclaimationTopology". >>> >>> Still says no data. >>> >>> -- >>> >>> 是故勝兵先勝而後求戰，敗兵先戰而後求勝。 > > > > -- > > 是故勝兵先勝而後求戰，敗兵先戰而後求勝。 -- 是故勝兵先勝而後求戰，敗兵先戰而後求勝。
