You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by sr...@apache.org on 2014/02/25 09:27:29 UTC
[19/19] git commit: Check delete state of topic
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 <sr...@gmail.com>
Authored: Tue Feb 25 00:26:14 2014 -0800
Committer: Sriram Subramanian <sr...@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)
}