[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/1.x-branch bf8437c20 -> 0a1f43310


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/10b165a2
Tree: http://git-wip-us.apache.org/repos/asf/storm/tree/10b165a2
Diff: http://git-wip-us.apache.org/repos/asf/storm/diff/10b165a2

Branch: refs/heads/1.x-branch
Commit: 10b165a2d0e9c5253395af7d8c086f4f979e6e1b
Parents: bf8437c
Author: Stig Rohde Døssing <s...@it-minds.dk>
Authored: Wed Nov 2 18:36:44 2016 +0100
Committer: Jungtaek Lim <kabh...@gmail.com>
Committed: Mon Nov 7 23:16:27 2016 +0900

----------------------------------------------------------------------
 .../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/10b165a2/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();
             }