Thank you Danijel ! Best,
Yunmeng 2014-02-28 3:03 GMT-05:00 Danijel Schiavuzzi <[email protected]>: > 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 >
