storm-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Joaquin Menchaca <jmench...@gobalto.com>
Subject Re: UI showing no topologies
Date Mon, 02 May 2016 09:33:14 GMT
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 <githubpoixen@gmail.com> 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 <jmenchaca@gobalto.com> 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.
>>
>> --
>>
>> 是故勝兵先勝而後求戰,敗兵先戰而後求勝。



-- 

是故勝兵先勝而後求戰,敗兵先戰而後求勝。

Mime
View raw message