#158 (#160)

remove old alias during new index with alias creation
grails · May 8, 2022 · b5f7fa3 · b5f7fa3
1 parent a0a16d5
commit b5f7fa3
Showing 1 changed file with 6 additions and 4 deletions.
diff --git a/grails-app/services/grails/plugins/elasticsearch/ElasticSearchAdminService.groovy b/grails-app/services/grails/plugins/elasticsearch/ElasticSearchAdminService.groovy
@@ -316,13 +316,15 @@ class ElasticSearchAdminService {
         LOG.debug "Creating alias ${alias}, pointing to index ${index} ..."
         String oldIndex = indexPointedBy(alias)
         elasticSearchHelper.withElasticSearch { RestHighLevelClient client ->
+            IndicesAliasesRequest request = new IndicesAliasesRequest()
             if (oldIndex && oldIndex != index) {
                 LOG.debug "Index used to point to ${oldIndex}, removing ..."
-                new IndicesAliasesRequest.AliasActions(IndicesAliasesRequest.AliasActions.Type.REMOVE)
-                        .index(oldIndex)
-                        .alias(alias)
+                IndicesAliasesRequest.AliasActions removeAliasAction = new IndicesAliasesRequest.AliasActions(IndicesAliasesRequest.AliasActions.Type.REMOVE)
+                    .index(oldIndex)
+                    .alias(alias)
+                request.addAliasAction(removeAliasAction)
             }
-            IndicesAliasesRequest request = new IndicesAliasesRequest()
+
             IndicesAliasesRequest.AliasActions aliasAction =
                     new IndicesAliasesRequest.AliasActions(IndicesAliasesRequest.AliasActions.Type.ADD)
                             .index(index)