from:"Qian, Shilei"

RE: Trident read from Kafka borkers, processes multiple times

2015-03-13 Thread Qian, Shilei

After I remove the storm configuration "topology.max.spout.pending", the trident workload runs well. But I still get a little confused if I should set this parameter to improve parallelism when processing trident topology. From: Qian, Shilei [mailto:shilei.q...@intel.com] Sent: Tues

Trident read from Kafka borkers, processes multiple times

2015-03-10 Thread Qian, Shilei

xecute(TridentTuple tuple, TridentCollector collector){ collector.emit(new Values(tuple.getValues())); } } Regards Qian, Shilei