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 e0fcbcd7ef79f..02c8386fda5ea 100644 --- a/server/src/main/java/org/opensearch/indices/replication/SegmentReplicationTargetService.java +++ b/server/src/main/java/org/opensearch/indices/replication/SegmentReplicationTargetService.java @@ -230,7 +230,7 @@ public synchronized void onNewCheckpoint(final ReplicationCheckpoint receivedChe ongoingReplicationTarget.getCheckpoint().getPrimaryTerm() ) ); - ongoingReplicationTarget.cancel("Cancelling ongoing target after new primary"); + ongoingReplicationTarget.cancel("Cancelling stuck target after new primary"); } else { logger.trace( () -> new ParameterizedMessage(