Another thing I observed while investigating is:
when I run "storm jar" command, it creates a directory
"Mytopology-2-1427302545" under "nimbus/stormdist". In that directory it has 3
files "stormcode.ser stormconf.ser stormjar.jar"
But after a while, these three files and the directory
"Mytopology-2-1427302545" are disappeared. I tried to manually create that
directory and copied back these three files, they are deleted (I guess by
storm) again.
On Wednesday, March 25, 2015 7:52 AM, S. Zhou <[email protected]> wrote:
output from "storm list"0 [main] INFO backtype.storm.thrift - Connecting
to Nimbus at localhost:6627No topologies running.
On Tuesday, March 24, 2015 9:53 PM, yuanjun Li <[email protected]> wrote:
use ./storm list to list your top status.
2015-03-25 9:52 GMT+08:00 S. Zhou <[email protected]>:
I used "storm jar" first actually. Then the topology was active for a short
period time then it dies. I checked log files from nimbus, ui, supervisor and
worker and found no error message.
On Tuesday, March 24, 2015 5:43 PM, Nathan Leung <[email protected]> wrote:
Is the topology already running? Given the exception I suspect not. You will
need to load it to the cluster using "storm jar ...". Activate should only be
used if the topology is already loaded to the cluster and deactivated (i.e.
spouts are not calling nextTuple).
On Tue, Mar 24, 2015 at 6:07 PM, S. Zhou <[email protected]> wrote:
I was running this command "./storm activate MyTopology" and got the following
exception. I looked through storm log files and could not see any clues. Any
hints? Thanks!
We are using storm 0.8.0 on Ubuntu Lucid (10.04).
0 [main] INFO backtype.storm.thrift - Connecting to Nimbus at
localhost:6627
Exception in thread "main" NotAliveException(msg:MyTopology)
at backtype.storm.generated.Nimbus$activate_result.read(Nimbus.java:4188)
at org.apache.thrift7.TServiceClient.receiveBase(TServiceClient.java:78)
at backtype.storm.generated.Nimbus$Client.recv_activate(Nimbus.java:210)
at backtype.storm.generated.Nimbus$Client.activate(Nimbus.java:197)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:622)
at clojure.lang.Reflector.invokeMatchingMethod(Reflector.java:93)
at clojure.lang.Reflector.invokeInstanceMethod(Reflector.java:28)
at backtype.storm.command.activate$_main.invoke(activate.clj:7)
at clojure.lang.AFn.applyToHelper(AFn.java:161)
at clojure.lang.AFn.applyTo(AFn.java:151)
at backtype.storm.command.activate.main(Unknown Source)
