ensure source factory is set before running any scheduled replications.

Signed-off-by: Marc Handalian <marc.handalian@gmail.com>
opensearch-project · Sep 3, 2024 · 16c6326 · 16c6326
1 parent e1570dd
commit 16c6326
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/server/src/main/java/org/opensearch/indices/replication/SegmentReplicator.java b/server/src/main/java/org/opensearch/indices/replication/SegmentReplicator.java
@@ -54,6 +54,7 @@ public SegmentReplicator(ThreadPool threadPool) {
     }
 
     public void scheduledReplication(IndexShard shard) {
+        if (sourceFactory.get() == null) return;
         startReplication(
             shard,
             shard.getLatestReplicationCheckpoint(),