diff --git a/solr/core/src/java/org/apache/solr/cloud/RecoveryStrategy.java b/solr/core/src/java/org/apache/solr/cloud/RecoveryStrategy.java index 94e126e6a71..67c15e856bd 100644 --- a/solr/core/src/java/org/apache/solr/cloud/RecoveryStrategy.java +++ b/solr/core/src/java/org/apache/solr/cloud/RecoveryStrategy.java @@ -606,11 +606,11 @@ public class RecoveryStrategy implements Runnable, Closeable { cloudDebugLog(core, "synced"); log.info("Replaying updates buffered during PeerSync."); - replay(core); + replayFuture = replay(core); // sync success successfulRecovery = true; - return; + break; } log.info("PeerSync Recovery was not successful - trying replication.");