kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject git commit: kafka-880; NoLeaderPartitionSet should be cleared before leader finder thread is started up; patched by Jun Rao; reviewed by Neha Narkhede
Date Fri, 26 Apr 2013 02:03:27 GMT
Updated Branches:
  refs/heads/0.8 2d7403174 -> 6e640e355


kafka-880; NoLeaderPartitionSet should be cleared before leader finder thread is started up;
patched by Jun Rao; reviewed by Neha Narkhede


Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/6e640e35
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/6e640e35
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/6e640e35

Branch: refs/heads/0.8
Commit: 6e640e355632d97e322e462c2bbc379c05d407a4
Parents: 2d74031
Author: Jun Rao <junrao@gmail.com>
Authored: Thu Apr 25 19:03:21 2013 -0700
Committer: Jun Rao <junrao@gmail.com>
Committed: Thu Apr 25 19:03:21 2013 -0700

----------------------------------------------------------------------
 .../kafka/consumer/ConsumerFetcherManager.scala    |    4 ++++
 1 files changed, 4 insertions(+), 0 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/6e640e35/core/src/main/scala/kafka/consumer/ConsumerFetcherManager.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/consumer/ConsumerFetcherManager.scala b/core/src/main/scala/kafka/consumer/ConsumerFetcherManager.scala
index d1373c9..c6250dc 100644
--- a/core/src/main/scala/kafka/consumer/ConsumerFetcherManager.scala
+++ b/core/src/main/scala/kafka/consumer/ConsumerFetcherManager.scala
@@ -129,6 +129,10 @@ class ConsumerFetcherManager(private val consumerIdString: String,
     info("Stopping all fetchers")
     closeAllFetchers()
 
+    // no need to hold the lock for the following since leaderFindThread and all fetchers
have been stopped
+    partitionMap = null
+    noLeaderPartitionSet.clear()
+
     info("All connections stopped")
   }
 


Mime
View raw message