Skip to content

Commit 98cabbd

Browse files
committed
Add additional failure branch
1 parent aa2b112 commit 98cabbd

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

server/src/main/java/org/elasticsearch/upgrades/SystemIndexMigrator.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -513,6 +513,8 @@ private <T> void deleteIndex(SystemIndexMigrationInfo migrationInfo, ActionListe
513513
if (ackedResponse.isAcknowledged()) {
514514
logger.info("successfully removed index [{}]", newIndexName);
515515
listener.onResponse(ackedResponse);
516+
} else {
517+
listener.onFailure(new ElasticsearchException("Failed to acknowledge index deletion for [" + newIndexName + "]"));
516518
}
517519
}, listener::onFailure));
518520
}

0 commit comments

Comments
 (0)