Clean up completedReplications when SegmentReplicator.cancel is invoked

guojialiang92 · guojialiang92 · commit 4ea54d1e9d58 · 2025-07-29T15:05:02.000+08:00
Signed-off-by: guojialiang &lt;guojialiang.2012@bytedance.com&gt;
diff --git a/server/src/main/java/org/opensearch/indices/replication/SegmentReplicator.java b/server/src/main/java/org/opensearch/indices/replication/SegmentReplicator.java
@@ -395,6 +395,7 @@ void cancel(ShardId shardId, String reason) {
         onGoingMergedSegmentReplications.cancelForShard(shardId, reason);
         replicationCheckpointStats.remove(shardId);
         primaryCheckpoint.remove(shardId);
+        completedReplications.remove(shardId);
     }
 
     SegmentReplicationTarget get(ShardId shardId) {

Original file line number	Diff line number	Diff line change
`@@ -395,6 +395,7 @@ void cancel(ShardId shardId, String reason) {`
`395`	`395`	`onGoingMergedSegmentReplications.cancelForShard(shardId, reason);`
`396`	`396`	`replicationCheckpointStats.remove(shardId);`
`397`	`397`	`primaryCheckpoint.remove(shardId);`
	`398`	`+ completedReplications.remove(shardId);`
`398`	`399`	`}`
`399`	`400`
`400`	`401`	`SegmentReplicationTarget get(ShardId shardId) {`