kafka-commits mailing list archives

Repository: kafka
Updated Branches:
  refs/heads/trunk c940470e3 -> a7e49298b


kafka-1681; Newly elected KafkaController might not start deletion of pending topics; patched
by Sriharsha Chintalapani; reviewed by Jun Rao


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

Branch: refs/heads/trunk
Commit: a7e49298b02ae35c227a40deae63debeae91138f
Parents: c940470
Author: Sriharsha Chintalapani <schintalapani@hortonworks.com>
Authored: Thu Oct 9 14:29:21 2014 -0700
Committer: Jun Rao <junrao@gmail.com>
Committed: Thu Oct 9 14:29:21 2014 -0700

----------------------------------------------------------------------
 core/src/main/scala/kafka/controller/TopicDeletionManager.scala | 2 ++
 1 file changed, 2 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/a7e49298/core/src/main/scala/kafka/controller/TopicDeletionManager.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/controller/TopicDeletionManager.scala b/core/src/main/scala/kafka/controller/TopicDeletionManager.scala
index 6ee3de2..e56f22d 100644
--- a/core/src/main/scala/kafka/controller/TopicDeletionManager.scala
+++ b/core/src/main/scala/kafka/controller/TopicDeletionManager.scala
@@ -89,6 +89,8 @@ class TopicDeletionManager(controller: KafkaController,
   def start() {
     if (isDeleteTopicEnabled) {
       deleteTopicsThread = new DeleteTopicsThread()
+      if (topicsToBeDeleted.size > 0)
+        deleteTopicStateChanged.set(true)
       deleteTopicsThread.start()
     }
   }