kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jun...@apache.org
Subject git commit: minor fix for KAFKA-1152; ReplicaManager's handling of the leaderAndIsrRequest should gracefully handle leader == -1; patched by Swapnil Ghike; reviewed by Jun Rao
Date Wed, 04 Dec 2013 00:50:26 GMT
Updated Branches:
  refs/heads/trunk ea3961fc8 -> 6c36beef8


minor fix for KAFKA-1152; ReplicaManager's handling of the leaderAndIsrRequest should gracefully
handle leader == -1; patched by Swapnil Ghike; reviewed by Jun Rao


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

Branch: refs/heads/trunk
Commit: 6c36beef873e8696e3e68b38c886893e01ce6dbb
Parents: ea3961f
Author: Swapnil Ghike <sghike@linkedin.com>
Authored: Tue Dec 3 16:50:18 2013 -0800
Committer: Jun Rao <junrao@gmail.com>
Committed: Tue Dec 3 16:50:18 2013 -0800

----------------------------------------------------------------------
 core/src/main/scala/kafka/server/ReplicaManager.scala | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/6c36beef/core/src/main/scala/kafka/server/ReplicaManager.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/server/ReplicaManager.scala b/core/src/main/scala/kafka/server/ReplicaManager.scala
index 49a0fa8..f9c7c29 100644
--- a/core/src/main/scala/kafka/server/ReplicaManager.scala
+++ b/core/src/main/scala/kafka/server/ReplicaManager.scala
@@ -365,10 +365,10 @@ class ReplicaManager(val config: KafkaConfig,
                 partitionAndOffsets.put(new TopicAndPartition(partition), 
                                         BrokerAndInitialOffset(leaderBroker, partition.getReplica().get.logEndOffset))
               case None =>
-                stateChangeLogger.trace("Broker %d ignored the become-follower state change
with correlation id %d " +
-                                        "controller %d epoch %d for topic-partition %s since
the designated leader %d " +
-                                        "cannot be found in live or shutting down brokers
%s"
-                                          .format(localBrokerId, correlationId, controllerId,
epoch, partition, leader, leaders))
+                stateChangeLogger.trace(("Broker %d ignored the become-follower state change
with correlation id %d " +
+                                         "controller %d epoch %d for topic-partition %s since
the designated leader %d " +
+                                         "cannot be found in live or shutting down brokers
%s")
+                                           .format(localBrokerId, correlationId, controllerId,
epoch, partition, leader, leaders))
             }
         }
         replicaFetcherManager.addFetcherForPartitions(partitionAndOffsets)


Mime
View raw message