You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@lucene.apache.org by ma...@apache.org on 2015/03/22 17:04:47 UTC
svn commit: r1668396 - in /lucene/dev/trunk/solr: CHANGES.txt
core/src/java/org/apache/solr/cloud/RecoveryStrategy.java
Author: markrmiller
Date: Sun Mar 22 16:04:46 2015
New Revision: 1668396
URL: http://svn.apache.org/r1668396
Log:
SOLR-7141: RecoveryStrategy: Raise time that we wait for any updates from the leader before they saw the recovery state to have finished.
Modified:
lucene/dev/trunk/solr/CHANGES.txt
lucene/dev/trunk/solr/core/src/java/org/apache/solr/cloud/RecoveryStrategy.java
Modified: lucene/dev/trunk/solr/CHANGES.txt
URL: http://svn.apache.org/viewvc/lucene/dev/trunk/solr/CHANGES.txt?rev=1668396&r1=1668395&r2=1668396&view=diff
==============================================================================
--- lucene/dev/trunk/solr/CHANGES.txt (original)
+++ lucene/dev/trunk/solr/CHANGES.txt Sun Mar 22 16:04:46 2015
@@ -272,6 +272,9 @@ Bug Fixes
* SOLR-7285: ActionThrottle will not pause if getNanoTime first returns 0.
(Mark Miller, Gregory Chanan)
+
+* SOLR-7141: RecoveryStrategy: Raise time that we wait for any updates from the leader before
+ they saw the recovery state to have finished. (Mark Miller)
Optimizations
----------------------
Modified: lucene/dev/trunk/solr/core/src/java/org/apache/solr/cloud/RecoveryStrategy.java
URL: http://svn.apache.org/viewvc/lucene/dev/trunk/solr/core/src/java/org/apache/solr/cloud/RecoveryStrategy.java?rev=1668396&r1=1668395&r2=1668396&view=diff
==============================================================================
--- lucene/dev/trunk/solr/core/src/java/org/apache/solr/cloud/RecoveryStrategy.java (original)
+++ lucene/dev/trunk/solr/core/src/java/org/apache/solr/cloud/RecoveryStrategy.java Sun Mar 22 16:04:46 2015
@@ -66,6 +66,7 @@ import java.util.concurrent.ExecutionExc
import java.util.concurrent.Future;
public class RecoveryStrategy extends Thread implements ClosableThread {
+ private static final int WAIT_FOR_UPDATES_WITH_STALE_STATE_PAUSE = Integer.getInteger("solr.cloud.wait-for-updates-with-stale-state-pause", 7000);
private static final int MAX_RETRIES = 500;
private static final int STARTING_RECOVERY_DELAY = 5000;
@@ -368,9 +369,10 @@ public class RecoveryStrategy extends Th
// we wait a bit so that any updates on the leader
// that started before they saw recovering state
- // are sure to have finished
+ // are sure to have finished (see SOLR-7141 for
+ // discussion around current value)
try {
- Thread.sleep(2000);
+ Thread.sleep(WAIT_FOR_UPDATES_WITH_STALE_STATE_PAUSE);
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
}