Skip to content

Commit 7f28330

Browse files
committed
Detact metadataFilesEligibleToDelete from its source collection
Signed-off-by: Peter Nied <peternied@hotmail.com>
1 parent 0663818 commit 7f28330

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

server/src/main/java/org/opensearch/index/store/RemoteSegmentStoreDirectory.java

+3-3
Original file line numberDiff line numberDiff line change
@@ -745,10 +745,10 @@ public void deleteStaleSegments(int lastNMetadataFilesToKeep) throws IOException
745745
return;
746746
}
747747

748-
List<String> metadataFilesEligibleToDelete = sortedMetadataFileList.subList(
748+
List<String> metadataFilesEligibleToDelete = new ArrayList<>(sortedMetadataFileList.subList(
749749
lastNMetadataFilesToKeep,
750750
sortedMetadataFileList.size()
751-
);
751+
));
752752
Set<String> allLockFiles;
753753
try {
754754
allLockFiles = ((RemoteStoreMetadataLockManager) mdLockManager).fetchLockedMetadataFiles(MetadataFilenameUtils.METADATA_PREFIX);
@@ -764,7 +764,7 @@ public void deleteStaleSegments(int lastNMetadataFilesToKeep) throws IOException
764764
logger.debug(
765765
"metadataFilesEligibleToDelete={} metadataFilesToBeDeleted={}",
766766
metadataFilesEligibleToDelete,
767-
metadataFilesEligibleToDelete
767+
metadataFilesToBeDeleted
768768
);
769769

770770
Map<String, UploadedSegmentMetadata> activeSegmentFilesMetadataMap = new HashMap<>();

0 commit comments

Comments
 (0)