Skip to content

Commit e13a11a

Browse files
committed
Do not re read repository name
1 parent e1995d7 commit e13a11a

File tree

1 file changed

+2
-9
lines changed

1 file changed

+2
-9
lines changed

server/src/main/java/org/elasticsearch/cluster/metadata/MetadataDeleteIndexService.java

Lines changed: 2 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -138,17 +138,10 @@ public ClusterState deleteIndices(ClusterState currentState, Set<Index> indices)
138138
final Map<String, Set<SnapshotId>> snapshotsToDelete = listOfSnapshotsToDelete(currentState, indicesToDelete);
139139
if (snapshotsToDelete.isEmpty() == false) {
140140
RepositoriesMetadata repositories = currentState.metadata().custom(RepositoriesMetadata.TYPE, RepositoriesMetadata.EMPTY);
141-
boolean changed = false;
142141
for (Map.Entry<String, Set<SnapshotId>> snapshotToDelete : snapshotsToDelete.entrySet()) {
143-
RepositoryMetadata repository = repositories.repository(snapshotToDelete.getKey());
144-
if (repository != null) {
145-
repositories = repositories.addSnapshotsToDelete(repository.name(), snapshotToDelete.getValue());
146-
changed = true;
147-
}
148-
}
149-
if (changed) {
150-
metadataBuilder.putCustom(RepositoriesMetadata.TYPE, repositories);
142+
repositories = repositories.addSnapshotsToDelete(snapshotToDelete.getKey(), snapshotToDelete.getValue());
151143
}
144+
metadataBuilder.putCustom(RepositoriesMetadata.TYPE, repositories);
152145
}
153146

154147
Metadata newMetadata = metadataBuilder.build();

0 commit comments

Comments
 (0)