[1/3] storm git commit: STORM-2184: Don't wakeup KafkaConsumer on shutdown, spout methods are not called by multiple threads at a time

[kabhwan]

Repository: storm
Updated Branches:
  refs/heads/master 5e0ece353 -> 6dc6407a0


STORM-2184: Don't wakeup KafkaConsumer on shutdown, spout methods are not 
called by multiple threads at a time


Project: http://git-wip-us.apache.org/repos/asf/storm/repo
Commit: http://git-wip-us.apache.org/repos/asf/storm/commit/10b9df27
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/10b9df27
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/10b9df27

Branch: refs/heads/master
Commit: 10b9df27c51e6c1bef8f519758d7a9f8d69659c5
Parents: 8911349
Author: Stig Rohde Døssing <s...@it-minds.dk>
Authored: Wed Nov 2 18:36:44 2016 +0100
Committer: Stig Rohde Døssing <s...@it-minds.dk>
Committed: Thu Nov 3 19:08:50 2016 +0100

----------------------------------------------------------------------
 .../src/main/java/org/apache/storm/kafka/spout/KafkaSpout.java      | 1 -
 1 file changed, 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/storm/blob/10b9df27/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpout.java
----------------------------------------------------------------------
diff --git 
a/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpout.java
 
b/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpout.java
index 4389acb..6b9e1b0 100644
--- 
a/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpout.java
+++ 
b/external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpout.java
@@ -386,7 +386,6 @@ public class KafkaSpout<K, V> extends BaseRichSpout {
 
     private void shutdown() {
         try {
-            kafkaConsumer.wakeup();
             if (!consumerAutoCommitMode) {
                 commitOffsetsForAckedTuples();
             }