Update warn logs in isSegmentReplicationAllowed.

Signed-off-by: Marc Handalian <[email protected]>
opensearch-project · Jan 6, 2023 · f8e001f · f8e001f
1 parent d22f9ac
commit f8e001f
Showing 1 changed file with 5 additions and 4 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
@@ -1445,21 +1445,22 @@ public ReplicationCheckpoint getLatestReplicationCheckpoint() {
      */
     public boolean isSegmentReplicationAllowed() {
         if (indexSettings.isSegRepEnabled() == false) {
+            logger.warn("Attempting to perform segment replication when it is not enabled on the index");
             return false;
         }
         if (getReplicationTracker().isPrimaryMode()) {
-            logger.warn("Ignoring new replication checkpoint - shard is in primaryMode and cannot receive any checkpoints.");
+            logger.warn("Shard is in primary mode and cannot perform segment replication as a replica.");
             return false;
         }
         if (this.routingEntry().primary()) {
-            logger.warn("Ignoring new replication checkpoint - primary shard cannot receive any checkpoints.");
+            logger.warn("Shard is marked as primary and cannot perform segment replication as a replica");
             return false;
         }
         if (state().equals(IndexShardState.STARTED) == false
             && (state() == IndexShardState.POST_RECOVERY && shardRouting.state() == ShardRoutingState.INITIALIZING) == false) {
             logger.warn(
                 () -> new ParameterizedMessage(
-                    "Ignoring new replication checkpoint - shard is not started or recovering {} {}",
+                    "Shard is not started or recovering {} {} and cannot perform segment replication as a replica",
                     state(),
                     shardRouting.state()
                 )
@@ -1469,7 +1470,7 @@ public boolean isSegmentReplicationAllowed() {
         if (getReplicationEngine().isEmpty()) {
             logger.warn(
                 () -> new ParameterizedMessage(
-                    "Ignoring checkpoint, attempting to perform segrep with wrong engine type {}",
+                    "Shard does not have the correct engine type to perform segment replication {}.",
                     getEngine().getClass()
                 )
             );