[GitHub] storm pull request #2438: STORM-2835: storm-kafka-client KafkaSpout can fail...

[hmcl]

Github user hmcl commented on a diff in the pull request:

    https://github.com/apache/storm/pull/2438#discussion_r155007745
  
    --- Diff: 
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpout.java
 ---
    @@ -242,9 +242,7 @@ public void nextTuple() {
                         }
                     }
     
    -                if (waitingToEmit()) {
    -                    emit();
    -                }
    +                emitIfWaitingNotEmitted();
    --- End diff --
    
    Done


---