Repository: kudu Updated Branches: refs/heads/master a833a1573 -> 0a397b2f7
[java client] Small fix to logging in AsyncKuduClient.tooManyAttemptsOrTimeout We were logging the RPC after calling errback on it, so some of the fields were already nulled out. Mostly a cosmetic change, for a DEBUG log line. Change-Id: If3df93be813c7fdf1626a06df14ff9b7585655fd Reviewed-on: http://gerrit.cloudera.org:8080/4948 Tested-by: Kudu Jenkins Reviewed-by: Adar Dembo <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/kudu/repo Commit: http://git-wip-us.apache.org/repos/asf/kudu/commit/43966599 Tree: http://git-wip-us.apache.org/repos/asf/kudu/tree/43966599 Diff: http://git-wip-us.apache.org/repos/asf/kudu/diff/43966599 Branch: refs/heads/master Commit: 43966599752830dcb584c1ee78263cae17c88ea0 Parents: a833a15 Author: Jean-Daniel Cryans <[email protected]> Authored: Wed Nov 2 16:22:02 2016 -0700 Committer: Adar Dembo <[email protected]> Committed: Fri Nov 4 19:34:40 2016 +0000 ---------------------------------------------------------------------- .../src/main/java/org/apache/kudu/client/AsyncKuduClient.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kudu/blob/43966599/java/kudu-client/src/main/java/org/apache/kudu/client/AsyncKuduClient.java ---------------------------------------------------------------------- diff --git a/java/kudu-client/src/main/java/org/apache/kudu/client/AsyncKuduClient.java b/java/kudu-client/src/main/java/org/apache/kudu/client/AsyncKuduClient.java index 2e2c0eb..06b9203 100644 --- a/java/kudu-client/src/main/java/org/apache/kudu/client/AsyncKuduClient.java +++ b/java/kudu-client/src/main/java/org/apache/kudu/client/AsyncKuduClient.java @@ -949,8 +949,8 @@ public class AsyncKuduClient implements AutoCloseable { } Status statusTimedOut = Status.TimedOut(message + request); final Exception e = new NonRecoverableException(statusTimedOut, cause); - request.errback(e); LOG.debug("Cannot continue with this RPC: {} because of: {}", request, message, e); + request.errback(e); return Deferred.fromError(e); }
