yujunjun/datahub
2
0
Fork 0
mirror of https://github.com/datahub-project/datahub.git synced 2025-12-29 02:48:24 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix(search): Fix index builder (#2884)

Browse Source
This commit is contained in:
Dexter Lee 2021-07-15 07:40:52 -07:00 committed by GitHub
parent f7df6959ed
commit 91414a5753
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
metadata-io/src/main/java/com/linkedin/metadata/search/elasticsearch/indexbuilder/IndexBuilder.java
View File

@ -99,9 +99,10 @@ public class IndexBuilder {
}
log.info("Reindex from {} to {} succeeded", indexName, tempIndexName);
String indexNamePattern = indexName + "_*";
// Check if the original index is aliased or not
GetAliasesResponse aliasesResponse =
searchClient.indices().getAlias(new GetAliasesRequest(indexName), RequestOptions.DEFAULT);
searchClient.indices().getAlias(new GetAliasesRequest(indexName).indices(indexNamePattern), RequestOptions.DEFAULT);
// If not aliased, delete the original index
if (aliasesResponse.getAliases().isEmpty()) {
searchClient.indices().delete(new DeleteIndexRequest().indices(indexName), RequestOptions.DEFAULT);
@ -112,7 +113,7 @@ public class IndexBuilder {
}
// Add alias for the new index
AliasActions removeAction = AliasActions.remove().alias(indexName).index("*");
AliasActions removeAction = AliasActions.remove().alias(indexName).index(indexNamePattern);
AliasActions addAction = AliasActions.add().alias(indexName).index(tempIndexName);
searchClient.indices()
.updateAliases(new IndicesAliasesRequest().addAliasAction(removeAction).addAliasAction(addAction),