im trying to push storm tuple to hdfs using rabbitmq im geting error like;

worker died

[Thread-21-RandomSentenceSpout] ERROR b.s.util - Halting process: ("Worker
died")
java.lang.RuntimeException: ("Worker died")
    at backtype.storm.util$exit_process_BANG_.doInvoke(util.clj:332)
[storm-core-0.10.0-beta1.jar:0.10.0-beta1]
    at clojure.lang.RestFn.invoke(RestFn.java:423) [clojure-1.6.0.jar:?]
    at
backtype.storm.daemon.worker$fn__5021$fn__5022.invoke(worker.clj:530)
[storm-core-0.10.0-beta1.jar:0.10.0-beta1]
    at
backtype.storm.daemon.executor$mk_executor_data$fn__4363$fn__4364.invoke(executor.clj:260)
[storm-core-0.10.0-beta1.jar:0.10.0-beta1]
    at backtype.storm.util$async_loop$fn__543.invoke(util.clj:485)
[storm-core-0.10.0-beta1.jar:0.10.0-beta1]
    at clojure.lang.AFn.run(AFn.java:22) [clojure-1.6.0.jar:?]

Reply via email to