diff --git a/server/src/main/java/org/opensearch/indices/replication/SegmentReplicationTargetService.java b/server/src/main/java/org/opensearch/indices/replication/SegmentReplicationTargetService.java
index fc7ef72b9a9f3..4f9bf7d60c25b 100644
--- a/server/src/main/java/org/opensearch/indices/replication/SegmentReplicationTargetService.java
+++ b/server/src/main/java/org/opensearch/indices/replication/SegmentReplicationTargetService.java
@@ -123,10 +123,9 @@ public void onReplicationDone(SegmentReplicationState state) {
                     if (latestReceivedCheckpoint.get(replicaShard.shardId()).isAheadOf(replicaShard.getLatestReplicationCheckpoint())) {
                         Runnable runnable = () -> onNewCheckpoint(latestReceivedCheckpoint.get(replicaShard.shardId()), replicaShard);
                         // Checks if we are using same thread and forks if necessary.
-                        if (thread == Thread.currentThread()){
+                        if (thread == Thread.currentThread()) {
                             threadPool.generic().execute(runnable);
-                        }
-                        else{
+                        } else {
                             runnable.run();
                         }
                     }