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 673e4a21e756e..d708c85afea7a 100644 --- a/server/src/main/java/org/opensearch/indices/replication/SegmentReplicationTargetService.java +++ b/server/src/main/java/org/opensearch/indices/replication/SegmentReplicationTargetService.java @@ -341,8 +341,7 @@ private void start(final long replicationId) { @Override public void onResponse(Void o) { onGoingReplications.markAsDone(replicationId); - if(target.state().getIndex().recoveredFileCount() != 0 - && target.state().getIndex().recoveredBytes() != 0) { + if (target.state().getIndex().recoveredFileCount() != 0 && target.state().getIndex().recoveredBytes() != 0) { completedReplications.put(target.shardId(), target); }