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

Reply via email to