Monitoring topology internal queues size

[Yury Ruchin <yu...@gmail.com>]

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

Re: Monitoring topology internal queues size

[Alex Merritt <me...@gmail.com>]

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.

Thanks,
Alex

On Wed, Feb 4, 2015 at 7:19 AM, Yury Ruchin <yu...@gmail.com> 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
>

Re: Monitoring topology internal queues size

[Tetsuya MATSUDA <te...@gmail.com>]

Hi, Yury

I'm sorry to answer your question, but I have question for you.

Have your internal queue overflowed?
If yes, what was happened after overflow?

I'm sorry reply with my question.

Tetsuya

On Wed, Feb 4, 2015 at 9:19 PM, Yury Ruchin <yu...@gmail.com> 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



-- 
松田 徹也　-Tetsuya MATSUDA-
E-mail : tetsuyam.ggl@gmail.com