kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject git commit: kafka-1168; OfflinePartitionCount in JMX can be incorrect during controlled shutdown; patched by Jun Rao; reviewed by Swapnil Ghike
Date Wed, 04 Dec 2013 23:46:15 GMT
Updated Branches:
  refs/heads/trunk 6c36beef8 -> 8a2ba3f6f


kafka-1168; OfflinePartitionCount in JMX can be incorrect during controlled shutdown; patched
by Jun Rao; reviewed by Swapnil Ghike


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

Branch: refs/heads/trunk
Commit: 8a2ba3f6f2eab88db4b5ea6d880ec2feba93276c
Parents: 6c36bee
Author: Jun Rao <junrao@gmail.com>
Authored: Wed Dec 4 15:47:18 2013 -0800
Committer: Jun Rao <junrao@gmail.com>
Committed: Wed Dec 4 15:47:18 2013 -0800

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


http://git-wip-us.apache.org/repos/asf/kafka/blob/8a2ba3f6/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 a1e0f29..3beaf75 100644
--- a/core/src/main/scala/kafka/controller/KafkaController.scala
+++ b/core/src/main/scala/kafka/controller/KafkaController.scala
@@ -134,7 +134,7 @@ class KafkaController(val config : KafkaConfig, zkClient: ZkClient) extends
Logg
           if (!isActive())
             0
           else
-            controllerContext.partitionLeadershipInfo.count(p => !controllerContext.liveBrokerIds.contains(p._2.leaderAndIsr.leader))
+            controllerContext.partitionLeadershipInfo.count(p => !controllerContext.liveOrShuttingDownBrokerIds.contains(p._2.leaderAndIsr.leader))
         }
       }
     }


Mime
View raw message