Hi Yunmeng, Take a look at the Config.setMaxSpoutPending() and Config.TRIDENT_BATCH_EMIT_INTERVAL_MILLIS parameters.
Regards, Danijel On Thu, Feb 27, 2014 at 10:51 PM, Yunmeng Ban <[email protected]> wrote: > Hi, > > I am benchmarking the latency of trident. I send tuples with timestamp in > batchs using a BatchSpout that implements IBatchSpout. But I found the > latency of the tuples keeps increasing. I found that the the emitBatch > executes every 1.7 seconds even I don't have any processing in the > BatchSpout, but I want spout to send tuples without blocking. > > Does anyone know how emitBatch works? How can I avoid blocking in > emitBatch? > > Thanks. > > Yunmeng > -- Danijel Schiavuzzi E: [email protected] W: www.schiavuzzi.com T: +385989035562 Skype: danijels7
