kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From nehanarkh...@apache.org
Subject git commit: partition state machine log4j change
Date Wed, 06 Feb 2013 04:02:42 GMT
Updated Branches:
  refs/heads/0.8 1086d001d -> aed6c3c03


partition state machine log4j change


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

Branch: refs/heads/0.8
Commit: aed6c3c0313ec00fa10b2fb0dd07658c96a99647
Parents: 1086d00
Author: Neha Narkhede <neha.narkhede@gmail.com>
Authored: Tue Feb 5 17:35:58 2013 -0800
Committer: Neha Narkhede <neha.narkhede@gmail.com>
Committed: Tue Feb 5 17:35:58 2013 -0800

----------------------------------------------------------------------
 .../kafka/controller/PartitionStateMachine.scala   |    5 +++--
 1 files changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/aed6c3c0/core/src/main/scala/kafka/controller/PartitionStateMachine.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/controller/PartitionStateMachine.scala b/core/src/main/scala/kafka/controller/PartitionStateMachine.scala
index 9bb318c..4078604 100644
--- a/core/src/main/scala/kafka/controller/PartitionStateMachine.scala
+++ b/core/src/main/scala/kafka/controller/PartitionStateMachine.scala
@@ -299,8 +299,9 @@ class PartitionStateMachine(controller: KafkaController) extends Logging
{
       brokerRequestBatch.addLeaderAndIsrRequestForBrokers(replicasForThisPartition, topic,
partition,
         newLeaderIsrAndControllerEpoch, controllerContext.partitionReplicaAssignment(TopicAndPartition(topic,
partition)).size)
     } catch {
-      case poe: PartitionOfflineException => throw new PartitionOfflineException("All
replicas for partition %s are dead."
-        .format(topicAndPartition) + " Marking this partition offline", poe)
+      case poe: PartitionOfflineException => throw new PartitionOfflineException("All
replicas %s for partition %s are dead."
+        .format(controllerContext.partitionReplicaAssignment(topicAndPartition).mkString(","),
topicAndPartition) +
+        " Marking this partition offline", poe)
       case sce => throw new StateChangeFailedException(("Error while electing leader for
partition " +
         " %s due to: %s.").format(topicAndPartition, sce.getMessage), sce)
     }


Mime
View raw message