You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@storm.apache.org by Vamsikrishna Vinjam <va...@inndata.in> on 2015/07/31 09:32:28 UTC

storm error

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:?]

Re: storm error

Posted by bhargav sarvepalli <bo...@gmail.com>.
No node exception occurs when there is no such folder in zookeeper.
Zookeeper contains folders that contain metadata for your queues. This is
the case in kafka, when you might have to create a new topic. I hope it is
the same with Rabbit mq

On Fri, Jul 31, 2015 at 2:24 PM, Vamsikrishna Vinjam <
vamsikrishna.vinjam@inndata.in> wrote:

>
> ---------- Forwarded message ----------
> From: Vamsikrishna Vinjam <va...@inndata.in>
> Date: Fri, Jul 31, 2015 at 1:02 PM
> Subject: storm error
> To: user@storm.apache.org
>
>
> im trying to push storm tuple to hdfs using rabbitmq im geting error like;
>
> worker died
>
> caused by org.apache.storm.zookeeper.KeeperException$NodeExistsException
>
>
>

Fwd: storm error

Posted by Vamsikrishna Vinjam <va...@inndata.in>.
---------- Forwarded message ----------
From: Vamsikrishna Vinjam <va...@inndata.in>
Date: Fri, Jul 31, 2015 at 1:02 PM
Subject: storm error
To: user@storm.apache.org


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

worker died

caused by org.apache.storm.zookeeper.KeeperException$NodeExistsException