You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@lucene.apache.org by ab...@apache.org on 2018/09/17 10:09:21 UTC
[36/44] lucene-solr:jira/solr-12709: SOLR-12766: Log retries after
the backoff
SOLR-12766: Log retries after the backoff
Project: http://git-wip-us.apache.org/repos/asf/lucene-solr/repo
Commit: http://git-wip-us.apache.org/repos/asf/lucene-solr/commit/a7a4f68d
Tree: http://git-wip-us.apache.org/repos/asf/lucene-solr/tree/a7a4f68d
Diff: http://git-wip-us.apache.org/repos/asf/lucene-solr/diff/a7a4f68d
Branch: refs/heads/jira/solr-12709
Commit: a7a4f68da5e3aa53206eba6b52512f73b6d41394
Parents: d6641ff
Author: Tomas Fernandez Lobbe <tf...@apache.org>
Authored: Thu Sep 13 20:46:38 2018 -0700
Committer: Tomas Fernandez Lobbe <tf...@apache.org>
Committed: Thu Sep 13 20:46:38 2018 -0700
----------------------------------------------------------------------
.../apache/solr/update/SolrCmdDistributor.java | 29 +++++++++-----------
1 file changed, 13 insertions(+), 16 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/lucene-solr/blob/a7a4f68d/solr/core/src/java/org/apache/solr/update/SolrCmdDistributor.java
----------------------------------------------------------------------
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 d7388f0..cb7f9cb 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);
}