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:04:08 GMT
Repository: kafka
Updated Branches:
  refs/heads/0.10.0 5aa20fb57 -> 946ae60a4


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

(cherry picked from commit ab7325928164b0cc7c26c695ecdf431ce1d89b8d)
Signed-off-by: Ewen Cheslack-Postava <me@ewencp.org>


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

Branch: refs/heads/0.10.0
Commit: 946ae60a4c8b694bfad65f20348d8081f103830b
Parents: 5aa20fb
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:04:01 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/946ae60a/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