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