kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ewe...@apache.org
Subject kafka git commit: KAFKA-3660: Log exception message in ControllerBrokerRequestBatch
Date Thu, 02 Jun 2016 04:03:56 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 61e0eaefd -> ab7325928


KAFKA-3660: Log exception message in ControllerBrokerRequestBatch

Author: Flavio Junqueira <fpj@apache.org>

Reviewers: Grant Henke <granthenke@gmail.com>, Ismael Juma <ismael@juma.me.uk>,
Ewen Cheslack-Postava <ewen@confluent.io>

Closes #1325 from fpj/KAFKA-3660


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

Branch: refs/heads/trunk
Commit: ab7325928164b0cc7c26c695ecdf431ce1d89b8d
Parents: 61e0eae
Author: Flavio Junqueira <fpj@apache.org>
Authored: Wed Jun 1 21:03:40 2016 -0700
Committer: Ewen Cheslack-Postava <me@ewencp.org>
Committed: Wed Jun 1 21:03:40 2016 -0700

----------------------------------------------------------------------
 .../main/scala/kafka/controller/ControllerChannelManager.scala | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/ab732592/core/src/main/scala/kafka/controller/ControllerChannelManager.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/controller/ControllerChannelManager.scala b/core/src/main/scala/kafka/controller/ControllerChannelManager.scala
index 65b7096..b4059a4 100755
--- a/core/src/main/scala/kafka/controller/ControllerChannelManager.scala
+++ b/core/src/main/scala/kafka/controller/ControllerChannelManager.scala
@@ -426,15 +426,15 @@ class ControllerBrokerRequestBatch(controller: KafkaController) extends
 Logging
       case e : Throwable => {
         if (leaderAndIsrRequestMap.size > 0) {
           error("Haven't been able to send leader and isr requests, current state of " +
-              s"the map is $leaderAndIsrRequestMap")
+              s"the map is $leaderAndIsrRequestMap. Exception message: $e")
         }
         if (updateMetadataRequestMap.size > 0) {
           error("Haven't been able to send metadata update requests, current state of " +
-              s"the map is $updateMetadataRequestMap")
+              s"the map is $updateMetadataRequestMap. Exception message: $e")
         }
         if (stopReplicaRequestMap.size > 0) {
           error("Haven't been able to send stop replica requests, current state of " +
-              s"the map is $stopReplicaRequestMap")
+              s"the map is $stopReplicaRequestMap. Exception message: $e")
         }
         throw new IllegalStateException(e)
       }


Mime
View raw message