From a7a4f68da5e3aa53206eba6b52512f73b6d41394 Mon Sep 17 00:00:00 2001 From: Tomas Fernandez Lobbe Date: Thu, 13 Sep 2018 20:46:38 -0700 Subject: [PATCH] SOLR-12766: Log retries after the backoff --- .../solr/update/SolrCmdDistributor.java | 29 +++++++++---------- 1 file changed, 13 insertions(+), 16 deletions(-) diff --git a/solr/core/src/java/org/apache/solr/update/SolrCmdDistributor.java b/solr/core/src/java/org/apache/solr/update/SolrCmdDistributor.java index d7388f0062c..cb7f9cb3b22 100644 --- a/solr/core/src/java/org/apache/solr/update/SolrCmdDistributor.java +++ b/solr/core/src/java/org/apache/solr/update/SolrCmdDistributor.java @@ -129,8 +129,6 @@ public class SolrCmdDistributor implements Closeable { for (Error err : errors) { try { - String oldNodeUrl = err.req.node.getUrl(); - /* * if this is a retryable request we may want to retry, depending on the error we received and * the number of times we have already retried @@ -143,20 +141,6 @@ public class SolrCmdDistributor implements Closeable { // this can happen in certain situations such as close if (isRetry) { err.req.retries++; - - if (err.req.node instanceof ForwardNode) { - SolrException.log(SolrCmdDistributor.log, "forwarding update to " - + oldNodeUrl + " failed - retrying ... retries: " - + err.req.retries + "/" + err.req.node.getMaxRetries() + ". " - + err.req.cmd.toString() + " params:" - + err.req.uReq.getParams() + " rsp:" + err.statusCode, err.e); - } else { - SolrException.log(SolrCmdDistributor.log, "FROMLEADER request to " - + oldNodeUrl + " failed - retrying ... retries: " - + err.req.retries + "/" + err.req.node.getMaxRetries() + ". " - + err.req.cmd.toString() + " params:" - + err.req.uReq.getParams() + " rsp:" + err.statusCode, err.e); - } resubmitList.add(err); } else { allErrors.add(err); @@ -182,6 +166,19 @@ public class SolrCmdDistributor implements Closeable { clients.clearErrors(); this.errors.clear(); for (Error err : resubmitList) { + if (err.req.node instanceof ForwardNode) { + SolrException.log(SolrCmdDistributor.log, "forwarding update to " + + err.req.node.getUrl() + " failed - retrying ... retries: " + + err.req.retries + "/" + err.req.node.getMaxRetries() + ". " + + err.req.cmd.toString() + " params:" + + err.req.uReq.getParams() + " rsp:" + err.statusCode, err.e); + } else { + SolrException.log(SolrCmdDistributor.log, "FROMLEADER request to " + + err.req.node.getUrl() + " failed - retrying ... retries: " + + err.req.retries + "/" + err.req.node.getMaxRetries() + ". " + + err.req.cmd.toString() + " params:" + + err.req.uReq.getParams() + " rsp:" + err.statusCode, err.e); + } submit(err.req, false); }