Conjecture - Could the bolt after the spout be the problem? Once the bolt input queue is full (I think the default is 1024 items), then it will pushback and Spout emit will block the spout thread. You could measure the time it took to emit for diagnostics.
Also- do you have 2 CPUs. Itai ________________________________________ From: Ahmed El Rheddane <[email protected]> Sent: Thursday, October 23, 2014 11:52 AM To: [email protected] Subject: Generating a constant load of tuples Hello again, I am trying to generate a regulated load of tuples using a sleep in the spout's nextTuple(). However, the observed results show that the number of tuples periodically drops by about 200 hundred tuples (from 800 to 600). I thought that this was due to the way I was monitoring Storm, but the behvior has been confirmed by local spout logs. I haven't set any limit on pending messages and I'm not using any ackers anyways. Any help would be very much appreciated. Cheers, Ahmed
