I don't know the "storm signals" project you mentioned. It might work for you. It is not part of storm-core system.
However, I do not understand why you write to a file and read from it again. Why not using one more bolt and just process the tuples there? I would also not sleep the spout in your case, but only sync writing/reading from file. -Matthias On 06/29/2015 04:00 PM, Pradheep s wrote: > 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 >>> >> >> >
signature.asc
Description: OpenPGP digital signature
