You can run into trouble trying to get a fixed time interval. If you haven't processed enough of the previous tuples, you can bring your topology to a halt. Proceed with caution.
On Wed, Mar 5, 2014 at 2:28 PM, Tian Guo <[email protected]> wrote: > I am developing some data analysis algorithms on top of Storm and have > some questions about the internal design of Storm. > > I want to simulate a sensor data yielding and processing in Storm, and > therefore I use Spout to push sensor data into the succeeding bolts at a > constant time interval via setting a sleep method in nextTuple method of > Spout. But from the experiment results, it appeared that spout didn't push > data at the specified rate. In the experiment, there was no bottleneck bolt > in the system. > > Therefore, my doubt is if the nextTuple method is called only when the > previous tuples are fully processed and acked in the ack method? > > If this is true, does it means that I cannot set a fixed time interval to > emit data? > > Thx a lot! > -- Ce n'est pas une signature
