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 <[email protected]> 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 >
