Exclude search replicas from sync

Signed-off-by: Prudhvi Godithi <[email protected]>
prudhvigodithi · Oct 24, 2024 · 6b59c82 · 6b59c82
1 parent ad7f9e7
commit 6b59c82
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 2 deletions.
diff --git a/gradle/run.gradle b/gradle/run.gradle
@@ -45,6 +45,7 @@ testClusters {
         plugin('plugins:'.concat(p))
       }
     }
+    setting 'opensearch.experimental.feature.read.write.split.enabled', 'true'
   }
 }
 

diff --git a/server/src/main/java/org/opensearch/index/shard/ReplicationGroup.java b/server/src/main/java/org/opensearch/index/shard/ReplicationGroup.java
@@ -78,7 +78,9 @@ public ReplicationGroup(
                 skippedShards.add(shard);
             } else {
                 if (trackedAllocationIds.contains(shard.allocationId().getId())) {
-                    replicationTargets.add(shard);
+                    if (!shard.isSearchOnly()) {
+                        replicationTargets.add(shard);
+                    }
                 } else {
                     assert inSyncAllocationIds.contains(shard.allocationId().getId()) == false : "in-sync shard copy but not tracked: "
                         + shard;
@@ -87,7 +89,9 @@ public ReplicationGroup(
                 if (shard.relocating()) {
                     ShardRouting relocationTarget = shard.getTargetRelocatingShard();
                     if (trackedAllocationIds.contains(relocationTarget.allocationId().getId())) {
-                        replicationTargets.add(relocationTarget);
+                        if (!relocationTarget.isSearchOnly()) {
+                            replicationTargets.add(relocationTarget);
+                        }
                     } else {
                         skippedShards.add(relocationTarget);
                         assert inSyncAllocationIds.contains(relocationTarget.allocationId().getId()) == false