storm-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Alex Merritt <>
Subject Re: Monitoring topology internal queues size
Date Fri, 27 Feb 2015 15:53:49 GMT
I wanted to revive this question. Is there a method to determine what tuple
queues exist and what their sizes are? If not, I can only think of creating
a queue within my own Bolts and create a separate thread that actually
performs the work, pulling items off the queue, while the execute()
function simply accepts a tuple and appends to the queue.

I'm asking as Bolts in a topology I have generate many new tuples with each
they receive, and would like to learn where there might be delays further
down the pipeline.


On Wed, Feb 4, 2015 at 7:19 AM, Yury Ruchin <> wrote:

> Hello,
> For Storm 0.9.3, I'd like to implement a metric to see the current queue
> size for a given bolt. Is there any way to observe the state of internal
> queues?
> Thanks,
> Yury

View raw message