kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From nehanarkh...@apache.org
Subject git commit: Minor log4j fix to ISR shrinking logic
Date Tue, 05 Feb 2013 23:04:23 GMT
Updated Branches:
  refs/heads/0.8 295734f6a -> 1086d001d


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/0.8
Commit: 1086d001d8f2389cd8cf409d099ca3260b00eb49
Parents: 295734f
Author: Neha Narkhede <neha.narkhede@gmail.com>
Authored: Tue Feb 5 15:04:18 2013 -0800
Committer: Neha Narkhede <neha.narkhede@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


Mime
View raw message