[Segment Replication] Handle update target cp for relocating primary

Signed-off-by: Suraj Singh <surajrider@gmail.com>
opensearch-project · Mar 20, 2023 · d6cc558 · d6cc558
1 parent 5f81930
commit d6cc558
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/server/src/main/java/org/opensearch/index/shard/IndexShard.java b/server/src/main/java/org/opensearch/index/shard/IndexShard.java
@@ -2725,9 +2725,11 @@ public void updateGlobalCheckpointForShard(final String allocationId, final long
      * @param visibleCheckpoint the visible checkpoint
      */
     public void updateVisibleCheckpointForShard(final String allocationId, final ReplicationCheckpoint visibleCheckpoint) {
-        assert assertPrimaryMode();
-        verifyNotClosed();
-        replicationTracker.updateVisibleCheckpointForShard(allocationId, visibleCheckpoint);
+        // Update target replication checkpoint only when in active primary mode
+        if (shardRouting.primary() && replicationTracker.isPrimaryMode()) {
+            verifyNotClosed();
+            replicationTracker.updateVisibleCheckpointForShard(allocationId, visibleCheckpoint);
+        }
     }
 
     /**