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 <[email protected]> Reviewers: Ewen Cheslack-Postava <[email protected]> Closes #871 from gwenshap/fix-cc-log (cherry picked from commit 9b47f9a7f631ad4c84ab305126e71d74968cc967) Signed-off-by: Ewen Cheslack-Postava <[email protected]> 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 <[email protected]> Authored: Thu Feb 4 14:34:29 2016 -0800 Committer: Ewen Cheslack-Postava <[email protected]> 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); + } } } );
