[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.0.x-branch e178efe45 -> 8f060e465


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

Branch: refs/heads/1.0.x-branch
Commit: a7a159e5e002bc3a0b581c221cb0cca38d194f2c
Parents: e178efe
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:17:09 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/a7a159e5/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 5a701d5..20e7e9a 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
@@ -371,7 +371,6 @@ public class KafkaSpout<K, V> extends BaseRichSpout {
 
     private void shutdown() {
         try {
-            kafkaConsumer.wakeup();
             if (!consumerAutoCommitMode) {
                 commitOffsetsForAckedTuples();
             }