Re:

By default it runs on 8080 if not you can look at storm.yaml for configured “ui.port --  Harsha On July 21, 2015 at 7:01:02 AM, Vamsikrishna Vinjam (vamsikrishna.vin...@inndata.in) wrote: storm web port number : im trying with 8772 but it is not working

Fwd: Storm topology freeze and slow down

Hi, I am running a topology in the 6 node cluster on RHEL 5 and Oracle JDK 1.7. Schematic for topology as attached, there are 6 workers for spout and bolts. Topology picks up message from JMS and sends out message to bolts. Each bolt does some processing and sends out next set of tuple to

Re: Storm topology freeze and slow down

Hello Manish, Do you make sure that you are ACK-ing tuples after processing? Nikos 2015-07-21 10:57 GMT-04:00 Manish Nema manish.k.n...@gmail.com: Hi, I am running a topology in the 6 node cluster on RHEL 5 and Oracle JDK 1.7. Schematic for topology as attached, there are 6 workers for

Re:

try shutdown the firewall...,maybe it works. 2015-07-21 23:27 GMT+08:00 Harsha st...@harsha.io: By default it runs on 8080 if not you can look at storm.yaml for configured “ui.port -- Harsha On July 21, 2015 at 7:01:02 AM, Vamsikrishna Vinjam ( vamsikrishna.vin...@inndata.in) wrote:

Getting Metrics from MetricsConsumer

Hi, Is there any way for the MetricsConsumer to send Metrics about itself to itself? Basically, I want to be able to track the % thread usage for a MetricsConsumer task so that I can figure out if I need to increase parallelism etc. I tried registering a Metric in the MetricConsumer's prepare

Getting Metrics from MetricsConsumer

Hi, Is there any way for the MetricsConsumer to send Metrics about itself to itself? Basically, I want to be able to track the % thread usage for a MetricsConsumer task so that I can figure out if I need to increase parallelism etc. I tried registering a Metric in the MetricConsumer's prepare

Re: Storm topology freeze and slow down

Hi Nikos Yes I am acking tuples in all bolt ...from all path in code Regards Manish On 21 Jul 2015 20:31, Nick R. Katsipoulakis nick.kat...@gmail.com wrote: Hello Manish, Do you make sure that you are ACK-ing tuples after processing? Nikos 2015-07-21 10:57 GMT-04:00 Manish Nema

Storrm worker issue .daemon.supervisor still hasn't started when using apostrophe char in launcher command

RE: What happens when a message times out?

So let’s say we have a single threaded topology with single worker. Doesn’t this mean that if a my computation gets stuck at some point all the messages in the queue get blocked too? Because the fail method will be called on the queue but there is no thread to process the next message. Is that

[no subject]

storm web port number : im trying with 8772 but it is not working

Getting Metrics from MetricsConsumer

Hi, Is there any way for the MetricsConsumer to send Metrics about itself to itself? Basically, I want to be able to track the % thread usage for a MetricsConsumer task so that I can figure out if I need to increase parallelism etc. I tried registering a Metric in the MetricConsumer's prepare