You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@storm.apache.org by Ankur Garg <an...@gmail.com> on 2015/10/12 22:57:45 UTC

Exception causing Cluster to fail

Hi ,

I am testing out my topologies on my local Cluster . Unfortunately ,
whenever some exception occurs , my Cluster stops with error message like
this :

{"timeStamp":1444673373185,"host":"mum-1agrag-m.local","tid":"Thread-11-eventSaver","loglevel":"error","msg":"Async
loop died!","source":"backtype.storm.utils/DisruptorQueue.java:128"}

{"timeStamp":1444673373199,"host":"mum-1agrag-m.local","tid":"Thread-11-eventSaver","loglevel":"error","msg":"","source":"backtype.storm.utils/DisruptorQueue.java:128"}

{"timeStamp":1444673373208,"host":"mum-1agrag-m.local","tid":"Thread-11-eventSaver","loglevel":"error","msg":"Halting
process: (\"Worker died\")","source":"backtype.storm/util.clj:325"}


Will the same happen when I deploy my topology to actual distributed
Cluster too ??


Also , If I catch these exceptions and not throw them the cluster continues
to run . But the stack trace for errors are not getting printed in the
console . I am catching all exceptions like below :

catch (Exception ex) {

LOG.error("Could not publish to the output Exchange ",ex);

}


Unfortunately though the Log message is getting printed , stack Trace is
not being thrown :( .


Looking for answers to above questions .


Thanks

Ankur