Skip to content

Commit 4ca7e7c

Browse files
nicer
1 parent 386f0c3 commit 4ca7e7c

File tree

1 file changed

+13
-7
lines changed

1 file changed

+13
-7
lines changed

server/src/main/java/org/elasticsearch/repositories/blobstore/BlobStoreRepository.java

Lines changed: 13 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -1265,13 +1265,19 @@ public void clusterStateProcessed(String source, ClusterState oldState, ClusterS
12651265
if (snapshotIdsWithoutVersion.isEmpty() == false) {
12661266
final Map<SnapshotId, Version> updatedVersionMap = new ConcurrentHashMap<>();
12671267
final GroupedActionListener<Void> loadAllVersionsListener = new GroupedActionListener<>(
1268-
ActionListener.wrap(() -> {
1269-
try {
1270-
filterRepositoryDataStep.onResponse(repositoryData.withVersions(updatedVersionMap));
1271-
} catch (Exception e) {
1272-
l.onFailure(e);
1273-
}
1274-
}), snapshotIdsWithoutVersion.size());
1268+
ActionListener.runAfter(
1269+
new ActionListener<>() {
1270+
@Override
1271+
public void onResponse(Collection<Void> voids) {
1272+
logger.info("Successfully loaded all snapshot's version information from snapshot metadata");
1273+
}
1274+
1275+
@Override
1276+
public void onFailure(Exception e) {
1277+
logger.warn("Failure when trying to load missing version information from snapshot metadata", e);
1278+
}
1279+
}, () -> filterRepositoryDataStep.onResponse(repositoryData.withVersions(updatedVersionMap))),
1280+
snapshotIdsWithoutVersion.size());
12751281
for (SnapshotId snapshotId : snapshotIdsWithoutVersion) {
12761282
threadPool().executor(ThreadPool.Names.SNAPSHOT).execute(ActionRunnable.run(loadAllVersionsListener, () ->
12771283
updatedVersionMap.put(snapshotId, getSnapshotInfo(snapshotId).version())));

0 commit comments

Comments
 (0)