Skip to content
Snippets Groups Projects
Commit 6d7721fd authored by Zhibin Mai's avatar Zhibin Mai Committed by David Diederich
Browse files

Failure to create the alias should not have impact on the status of index creation

(cherry picked from commit eab4a842)
parent 9b38530e
No related branches found
No related tags found
Loading
......@@ -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) {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment