Change back info to trace logs in target service.

Signed-off-by: Rishikesh1159 <[email protected]>
sachinpkale · Sep 29, 2023 · a4df5f5 · a4df5f5
1 parent 19815a8
commit a4df5f5
Showing 1 changed file with 7 additions and 7 deletions.
diff --git a/server/src/main/java/org/opensearch/indices/replication/SegmentReplicationTargetService.java b/server/src/main/java/org/opensearch/indices/replication/SegmentReplicationTargetService.java
@@ -212,7 +212,7 @@ public synchronized void onNewCheckpoint(final ReplicationCheckpoint receivedChe
         // if the shard is in any state
         if (replicaShard.state().equals(IndexShardState.CLOSED)) {
             // ignore if shard is closed
-            logger.info(() -> "Ignoring checkpoint, Shard is closed");
+            logger.trace(() -> "Ignoring checkpoint, Shard is closed");
             return;
         }
         updateLatestReceivedCheckpoint(receivedCheckpoint, replicaShard);
@@ -281,7 +281,7 @@ public void onReplicationFailure(
                 });
             }
         } else {
-            logger.info(
+            logger.trace(
                 () -> new ParameterizedMessage("Ignoring checkpoint, shard not started {} {}", receivedCheckpoint, replicaShard.state())
             );
         }
@@ -330,7 +330,7 @@ protected void updateVisibleCheckpoint(long replicationId, IndexShard replicaSha
         final TransportRequestOptions options = TransportRequestOptions.builder()
             .withTimeout(recoverySettings.internalActionTimeout())
             .build();
-        logger.info(
+        logger.trace(
             () -> new ParameterizedMessage(
                 "Updating Primary shard that replica {}-{} is synced to checkpoint {}",
                 replicaShard.shardId(),
@@ -347,7 +347,7 @@ protected void updateVisibleCheckpoint(long replicationId, IndexShard replicaSha
         final ActionListener<Void> listener = new ActionListener<>() {
             @Override
             public void onResponse(Void unused) {
-                logger.info(
+                logger.trace(
                     () -> new ParameterizedMessage(
                         "Successfully updated replication checkpoint {} for replica {}",
                         replicaShard.shardId(),
@@ -386,7 +386,7 @@ private DiscoveryNode getPrimaryNode(ShardRouting primaryShard) {
     protected boolean processLatestReceivedCheckpoint(IndexShard replicaShard, Thread thread) {
         final ReplicationCheckpoint latestPublishedCheckpoint = latestReceivedCheckpoint.get(replicaShard.shardId());
         if (latestPublishedCheckpoint != null && latestPublishedCheckpoint.isAheadOf(replicaShard.getLatestReplicationCheckpoint())) {
-            logger.info(
+            logger.trace(
                 () -> new ParameterizedMessage(
                     "Processing latest received checkpoint for shard {} {}",
                     replicaShard.shardId(),
@@ -448,7 +448,7 @@ void startReplication(final SegmentReplicationTarget target) {
             target.fail(e, false);
             return;
         }
-        logger.info(() -> new ParameterizedMessage("Added new replication to collection {}", target.description()));
+        logger.trace(() -> new ParameterizedMessage("Added new replication to collection {}", target.description()));
         threadPool.generic().execute(new ReplicationRunner(replicationId));
     }
 
@@ -573,7 +573,7 @@ private void forceReplication(ForceSyncRequest request, ActionListener<Transport
                     @Override
                     public void onReplicationDone(SegmentReplicationState state) {
                         try {
-                            logger.info(
+                            logger.trace(
                                 () -> new ParameterizedMessage(
                                     "[shardId {}] [replication id {}] Force replication Sync complete to {}, timing data: {}",
                                     shardId,