kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sriram...@apache.org
Subject [19/19] git commit: Check delete state of topic
Date Tue, 25 Feb 2014 08:27:29 GMT
Check delete state of topic


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

Branch: refs/heads/trunk
Commit: 00afb619cb1f2aaca0ddc785ab1d649428f9c93e
Parents: 5b80758
Author: Sriram Subramanian <sriram.sub@gmail.com>
Authored: Tue Feb 25 00:26:14 2014 -0800
Committer: Sriram Subramanian <sriram.sub@gmail.com>
Committed: Tue Feb 25 00:26:14 2014 -0800

----------------------------------------------------------------------
 core/src/main/scala/kafka/controller/KafkaController.scala | 1 -
 1 file changed, 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/00afb619/core/src/main/scala/kafka/controller/KafkaController.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/controller/KafkaController.scala b/core/src/main/scala/kafka/controller/KafkaController.scala
index f12ffc2..b58cdcd 100644
--- a/core/src/main/scala/kafka/controller/KafkaController.scala
+++ b/core/src/main/scala/kafka/controller/KafkaController.scala
@@ -1114,7 +1114,6 @@ class KafkaController(val config : KafkaConfig, zkClient: ZkClient)
extends Logg
                       controllerContext.partitionsBeingReassigned.size == 0 &&
                       controllerContext.partitionsUndergoingPreferredReplicaElection.size
== 0 &&
                       !deleteTopicManager.isTopicQueuedUpForDeletion(topicPartition.topic)
&&
-                      !deleteTopicManager.isTopicDeletionInProgress(topicPartition.topic)
&&
                       controllerContext.allTopics.contains(topicPartition.topic)) {
                     onPreferredReplicaElection(Set(topicPartition), false)
                   }


Mime
View raw message