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 3a65f170d7b..d7388f0062c 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) {