storm-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Ankur Garg <ankurga...@gmail.com>
Subject Exception causing Cluster to fail
Date Mon, 12 Oct 2015 20:57:45 GMT
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

Mime
View raw message