Keep the old assertion same for non remote backed indexes

Signed-off-by: Sachin Kale <[email protected]>
opensearch-project · Dec 14, 2023 · 833c1b6 · 833c1b6
1 parent 303eff0
commit 833c1b6
Showing 1 changed file with 7 additions and 6 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
@@ -3433,12 +3433,6 @@ public void activateWithPrimaryContext(final ReplicationTracker.PrimaryContext p
             + "] does not contain relocation target ["
             + routingEntry()
             + "]";
-        assert getLocalCheckpoint() >= primaryContext.getCheckpointStates().get(routingEntry().allocationId().getId()).getLocalCheckpoint()
-            || indexSettings().getTranslogDurability() == Durability.ASYNC : "local checkpoint ["
-                + getLocalCheckpoint()
-                + "] does not match checkpoint from primary context ["
-                + primaryContext
-                + "]";
         if (isRemoteStoreEnabled()) {
             assert getLocalCheckpoint() == primaryContext.getCheckpointStates()
                 .get(primaryContext.getRoutingTable().primaryShard().allocationId().getId())
@@ -3447,6 +3441,13 @@ assert getLocalCheckpoint() == primaryContext.getCheckpointStates()
                     + "] does not match checkpoint from local checkpoint of old primary for remote store backed index ["
                     + primaryContext
                     + "]";
+        } else {
+            assert getLocalCheckpoint() == primaryContext.getCheckpointStates().get(routingEntry().allocationId().getId()).getLocalCheckpoint()
+                || indexSettings().getTranslogDurability() == Durability.ASYNC : "local checkpoint ["
+                + getLocalCheckpoint()
+                + "] does not match checkpoint from primary context ["
+                + primaryContext
+                + "]";
         }
         synchronized (mutex) {
             replicationTracker.activateWithPrimaryContext(primaryContext); // make changes to primaryMode flag only under mutex