You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@lucene.apache.org by da...@apache.org on 2018/09/14 03:30:58 UTC
[41/43] lucene-solr:jira/http2: SOLR-12766: Backoff time for internal
requests is never more than 2 seconds
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/9f37a6be
Tree: http://git-wip-us.apache.org/repos/asf/lucene-solr/tree/9f37a6be
Diff: http://git-wip-us.apache.org/repos/asf/lucene-solr/diff/9f37a6be
Branch: refs/heads/jira/http2
Commit: 9f37a6be9bea011a98d769692560ea41d6fb3d08
Parents: dea3d69
Author: Tomas Fernandez Lobbe <tf...@apache.org>
Authored: Thu Sep 13 08:43:10 2018 -0700
Committer: Tomas Fernandez Lobbe <tf...@apache.org>
Committed: Thu Sep 13 08:43:10 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/9f37a6be/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) {