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 <sharmajayan...@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 >
