storm-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Jayant Sharma <>
Subject When is the MAX_SPOUT_PENDING limit applied
Date Wed, 03 Apr 2019 09:49:52 GMT

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?

Jayant Sharma

View raw message