Github user arunmahadevan commented on the issue:

    https://github.com/apache/storm/pull/2829
  
    >what's the motivation to change this to LinkedList?
    
    Its mentioned in the description. Heres the relevant code for some more 
details - 
https://github.com/apache/storm/blob/master/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpout.java#L422
    
    >nextTuple emits only a single tuple because that's the contract of the 
method nextTuple, which must be honored. This was thoroughly discussed in the 
patch with the initial code implementation.
    
    It can emit one or more and ideally should emit whatever it has to emit at 
that point.
    
https://github.com/apache/storm/blob/master/storm-client/src/jvm/org/apache/storm/spout/ISpout.java#L72
    



---

Reply via email to