storm-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Joshua Martell <joshua.mart...@gmail.com>
Subject Re: When is the MAX_SPOUT_PENDING limit applied
Date Wed, 03 Apr 2019 12:45:12 GMT
I’m pretty sure it’s per spout task. And they’re not coordinated. Each task
gets its own count.

Joshua
On Wed, Apr 3, 2019 at 4:50 AM Jayant Sharma <sharmajayant27@gmail.com>
wrote:

> Hi,
>
> Can someone please explain at what point storm checks and applies
> MAX_SPOUT_PENDING limit. Also, is this limit applied per executor(or Task
> if that's the case) of spout or aggregated and applied over all the
> executors of spout.
> Suppose I have 3 executors and 3 tasks of spouts, each of them fetch 1
> message from input source. If my MAX_SPOUT_PENDING is 2, will only 2
> executors be able to send the tuple forward or all 3 will send and further
> nextTuple calls on all will be blocked?
>
> Thanks,
> Jayant Sharma
>

Mime
View raw message