lucene-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tflo...@apache.org
Subject [2/2] lucene-solr:branch_7_5: SOLR-12766: Backoff time for internal requests is never more than 2 seconds
Date Thu, 13 Sep 2018 21:10:55 GMT
SOLR-12766: Backoff time for internal requests is never more than 2 seconds


Project: http://git-wip-us.apache.org/repos/asf/lucene-solr/repo
Commit: http://git-wip-us.apache.org/repos/asf/lucene-solr/commit/f5b00707
Tree: http://git-wip-us.apache.org/repos/asf/lucene-solr/tree/f5b00707
Diff: http://git-wip-us.apache.org/repos/asf/lucene-solr/diff/f5b00707

Branch: refs/heads/branch_7_5
Commit: f5b00707a6064a34af013b2e18c322d613926319
Parents: 2ce0f52
Author: Tomas Fernandez Lobbe <tflobbe@apache.org>
Authored: Thu Sep 13 08:43:10 2018 -0700
Committer: Tomas Fernandez Lobbe <tflobbe@apache.org>
Committed: Thu Sep 13 14:09:17 2018 -0700

----------------------------------------------------------------------
 solr/core/src/java/org/apache/solr/update/SolrCmdDistributor.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/lucene-solr/blob/f5b00707/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 3a65f17..d7388f0 100644
--- a/solr/core/src/java/org/apache/solr/update/SolrCmdDistributor.java
+++ b/solr/core/src/java/org/apache/solr/update/SolrCmdDistributor.java
@@ -170,7 +170,7 @@ public class SolrCmdDistributor implements Closeable {
     if (resubmitList.size() > 0) {
       // Only backoff once for the full batch
       try {
-        int backoffTime = retryPause * resubmitList.get(0).req.retries;
+        int backoffTime = Math.min(retryPause * resubmitList.get(0).req.retries, 2000);
         log.debug("Sleeping {}ms before re-submitting {} requests", backoffTime, resubmitList.size());
         Thread.sleep(backoffTime);
       } catch (InterruptedException e) {


Mime
View raw message