[GitHub] storm pull request #2454: STORM-2847: Ensure spout can handle being activate...

[hmcl]

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

    https://github.com/apache/storm/pull/2454#discussion_r156208684
  
    --- Diff: 
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpout.java
 ---
    @@ -223,29 +220,24 @@ private long doSeek(TopicPartition tp, 
OffsetAndMetadata committedOffset) {
         @Override
         public void nextTuple() {
             try {
    -            if (initialized) {             
    --- End diff --
    
    Why is this flag no longer necessary?


---