Hi, The problem i have is that, i write the tuples received form a spout to a file through a bolt. I also use another thread to read form it. Sometime the writer might overtake reader and override tuple which the reader has to read and lose tuples. So i have to avoid this.. I heard about two things, i have to give back the control from bolt to spout in order for spout to sent the next tuple. is this right or the spot continuously sends the tuples whatever the bolt does with it? Next is about storm signals https://github.com/ptgoetz/storm-signals, is this feature available , so that i can try to send a sleep signal to spout whenever i need?
Thanks, Pradheep On Mon, Jun 29, 2015 at 5:16 AM, Matthias J. Sax < mj...@informatik.hu-berlin.de> wrote: > 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 > > > >
