kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ewe...@apache.org
Subject kafka git commit: MINOR: log connect reconfiguration error only if there was an error
Date Thu, 04 Feb 2016 22:34:43 GMT
Repository: kafka
Updated Branches:
  refs/heads/0.9.0 90ce9b300 -> c6ecc7809


MINOR: log connect reconfiguration error only if there was an error

Author: Gwen Shapira <cshapi@gmail.com>

Reviewers: Ewen Cheslack-Postava <ewen@confluent.io>

Closes #871 from gwenshap/fix-cc-log

(cherry picked from commit 9b47f9a7f631ad4c84ab305126e71d74968cc967)
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/c6ecc780
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/c6ecc780
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/c6ecc780

Branch: refs/heads/0.9.0
Commit: c6ecc780988316de14fc4d27aa3ae8d5d253171c
Parents: 90ce9b3
Author: Gwen Shapira <cshapi@gmail.com>
Authored: Thu Feb 4 14:34:29 2016 -0800
Committer: Ewen Cheslack-Postava <me@ewencp.org>
Committed: Thu Feb 4 14:34:38 2016 -0800

----------------------------------------------------------------------
 .../kafka/connect/runtime/distributed/DistributedHerder.java   | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/kafka/blob/c6ecc780/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java
----------------------------------------------------------------------
diff --git a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java
b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java
index 85db168..0c4d1d0 100644
--- a/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java
+++ b/connect/runtime/src/main/java/org/apache/kafka/connect/runtime/distributed/DistributedHerder.java
@@ -456,8 +456,10 @@ public class DistributedHerder implements Herder, Runnable {
                 new Callback<Void>() {
                     @Override
                     public void onCompletion(Throwable error, Void result) {
-                        log.error("Unexpected error during task reconfiguration: ", error);
-                        log.error("Task reconfiguration for {} failed unexpectedly, this
connector will not be properly reconfigured unless manually triggered.", connName);
+                        if (error != null) {
+                            log.error("Unexpected error during task reconfiguration: ", error);
+                            log.error("Task reconfiguration for {} failed unexpectedly, this
connector will not be properly reconfigured unless manually triggered.", connName);
+                        }
                     }
                 }
         );


Mime
View raw message