From 90bf8bb159624eac1643acb8b2656dcf71a75ee6 Mon Sep 17 00:00:00 2001 From: Prudhvi Godithi Date: Thu, 24 Oct 2024 11:24:04 -0700 Subject: [PATCH] Exclude search replicas from sync Signed-off-by: Prudhvi Godithi --- .../java/org/opensearch/index/shard/ReplicationGroup.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/server/src/main/java/org/opensearch/index/shard/ReplicationGroup.java b/server/src/main/java/org/opensearch/index/shard/ReplicationGroup.java index ccfaf50da1c6b..604f8dac65418 100644 --- a/server/src/main/java/org/opensearch/index/shard/ReplicationGroup.java +++ b/server/src/main/java/org/opensearch/index/shard/ReplicationGroup.java @@ -77,7 +77,7 @@ public ReplicationGroup( assert shard.primary() == false : "primary shard should not be unassigned in a replication group: " + shard; skippedShards.add(shard); } else { - if (trackedAllocationIds.contains(shard.allocationId().getId())) { + if (trackedAllocationIds.contains(shard.allocationId().getId()) && !shard.isSearchOnly()) { replicationTargets.add(shard); } else { assert inSyncAllocationIds.contains(shard.allocationId().getId()) == false : "in-sync shard copy but not tracked: " @@ -86,7 +86,7 @@ public ReplicationGroup( } if (shard.relocating()) { ShardRouting relocationTarget = shard.getTargetRelocatingShard(); - if (trackedAllocationIds.contains(relocationTarget.allocationId().getId())) { + if (trackedAllocationIds.contains(relocationTarget.allocationId().getId()) && !relocationTarget.isSearchOnly()) { replicationTargets.add(relocationTarget); } else { skippedShards.add(relocationTarget);