It depends what you want so accomplish... You can always "sleep" in Spout.nextTuple() to block the spout for a finite time.
As an alternative, you can limit the number of pending tuples be setting parameter "topology.max.spout.pending" (be aware that tuples might time out in this case). Sending a signal from bolt to spout is not supported by Storm. If you want to do this, you need to code it by yourself. But it is tricky to do, I would not recommend it. -Matthias On 06/28/2015 05:51 PM, Pradheep s wrote: > Hi, > > I have a spout which is emitting random numbers continuously to a bolt > which received them. Is it possible to block the spout for a finite time > from sending the tuples to the bolt? i have to send a blocking signal from > the bolt to spout?if possible how to do it? > Please let me know if someone can give some about this. > > Thanks, > Pradheep >
signature.asc
Description: OpenPGP digital signature
