You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ju...@apache.org on 2013/03/04 05:22:03 UTC
[5/37] git commit: Minor log4j fix to ISR shrinking logic
Minor log4j fix to ISR shrinking logic
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/1086d001
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/1086d001
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/1086d001
Branch: refs/heads/trunk
Commit: 1086d001d8f2389cd8cf409d099ca3260b00eb49
Parents: 295734f
Author: Neha Narkhede <ne...@gmail.com>
Authored: Tue Feb 5 15:04:18 2013 -0800
Committer: Neha Narkhede <ne...@gmail.com>
Committed: Tue Feb 5 15:04:18 2013 -0800
----------------------------------------------------------------------
core/src/main/scala/kafka/cluster/Partition.scala | 3 ++-
1 files changed, 2 insertions(+), 1 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka/blob/1086d001/core/src/main/scala/kafka/cluster/Partition.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/cluster/Partition.scala b/core/src/main/scala/kafka/cluster/Partition.scala
index 71eb980..b55b464 100644
--- a/core/src/main/scala/kafka/cluster/Partition.scala
+++ b/core/src/main/scala/kafka/cluster/Partition.scala
@@ -269,7 +269,8 @@ class Partition(val topic: String,
if(outOfSyncReplicas.size > 0) {
val newInSyncReplicas = inSyncReplicas -- outOfSyncReplicas
assert(newInSyncReplicas.size > 0)
- info("Shrinking ISR for topic %s partition %d to %s".format(topic, partitionId, newInSyncReplicas.map(_.brokerId).mkString(",")))
+ info("Shrinking ISR for topic %s partition %d from %s to %s".format(topic, partitionId,
+ inSyncReplicas.map(_.brokerId).mkString(","), newInSyncReplicas.map(_.brokerId).mkString(",")))
// update ISR in zk and in cache
updateIsr(newInSyncReplicas)
// we may need to increment high watermark since ISR could be down to 1