diff --git a/indexer-core/src/main/java/org/opengroup/osdu/indexer/service/IndicesServiceImpl.java b/indexer-core/src/main/java/org/opengroup/osdu/indexer/service/IndicesServiceImpl.java index dd821395188d20a0a5291cc8d7fbaf26d0aa8f53..8b4d879693f3377dcd4199cd1dcc1db06b9fe0c7 100644 --- a/indexer-core/src/main/java/org/opengroup/osdu/indexer/service/IndicesServiceImpl.java +++ b/indexer-core/src/main/java/org/opengroup/osdu/indexer/service/IndicesServiceImpl.java @@ -307,22 +307,28 @@ public class IndicesServiceImpl implements IndicesService { } } - private void createIndexAlias(RestHighLevelClient client, String index) throws IOException { + private void createIndexAlias(RestHighLevelClient client, String index) { String kind = this.elasticIndexNameResolver.getKindFromIndexName(index); String kindWithMajorVersion = getKindWithMajorVersion(kind); - for (String kd : Arrays.asList(kind, kindWithMajorVersion)) { - index = elasticIndexNameResolver.getIndexNameFromKind(kd); - String alias = elasticIndexNameResolver.getIndexAliasFromKind(kd); - IndicesAliasesRequest addRequest = new IndicesAliasesRequest(); - IndicesAliasesRequest.AliasActions aliasActions = new IndicesAliasesRequest.AliasActions(IndicesAliasesRequest.AliasActions.Type.ADD) - .index(index) - .alias(alias); - addRequest.addAliasAction(aliasActions); - AcknowledgedResponse response = client.indices().updateAliases(addRequest, RequestOptions.DEFAULT); - if (response.isAcknowledged()) { - this.log.info(String.format("Alias %s was created for index %s", alias, index)); + try { + for (String kd : Arrays.asList(kind, kindWithMajorVersion)) { + index = elasticIndexNameResolver.getIndexNameFromKind(kd); + String alias = elasticIndexNameResolver.getIndexAliasFromKind(kd); + IndicesAliasesRequest addRequest = new IndicesAliasesRequest(); + IndicesAliasesRequest.AliasActions aliasActions = new IndicesAliasesRequest.AliasActions(IndicesAliasesRequest.AliasActions.Type.ADD) + .index(index) + .alias(alias); + addRequest.addAliasAction(aliasActions); + AcknowledgedResponse response = client.indices().updateAliases(addRequest, RequestOptions.DEFAULT); + if (response.isAcknowledged()) { + this.log.info(String.format("Alias %s was created for index %s", alias, index)); + } } } + catch(Exception ex) { + // Failed to create alias is not the end. It should not affect the status of index creation + this.log.error(String.format("Fail to create aliases for index %s", index), ex); + } } private String getKindWithMajorVersion(String kind) {