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 <yuri.ruchin@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
>
|