[Segment Replication] Close writer on segment replication cancellation (

#7062) Signed-off-by: Suraj Singh <[email protected]>
opensearch-project · Apr 11, 2023 · b4e361c · b4e361c
1 parent df5def4
commit b4e361c
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/server/src/main/java/org/opensearch/indices/replication/SegmentReplicationTarget.java b/server/src/main/java/org/opensearch/indices/replication/SegmentReplicationTarget.java
@@ -292,5 +292,6 @@ private ChecksumIndexInput toIndexInput(byte[] input) {
     protected void onCancel(String reason) {
         cancellableThreads.cancel(reason);
         source.cancel();
+        multiFileWriter.close();
     }
 }