Skip to content

Commit 098928c

Browse files
committed
Fix refresh for delete synonym rule
1 parent 1792888 commit 098928c

File tree

1 file changed

+20
-12
lines changed

1 file changed

+20
-12
lines changed

server/src/main/java/org/elasticsearch/synonyms/SynonymsManagementAPIService.java

+20-12
Original file line numberDiff line numberDiff line change
@@ -354,7 +354,7 @@ public void putSynonymsSet(
354354
? UpdateSynonymsResultStatus.CREATED
355355
: UpdateSynonymsResultStatus.UPDATED;
356356

357-
maybeReloadAnalyzers(synonymSetId, refresh, false, updateSynonymsResultStatus, bulkInsertResponseListener);
357+
checkIndexSearchableAndReloadAnalyzers(synonymSetId, refresh, false, updateSynonymsResultStatus, bulkInsertResponseListener);
358358
})
359359
);
360360
}));
@@ -424,7 +424,7 @@ private void indexSynonymRule(
424424
? UpdateSynonymsResultStatus.CREATED
425425
: UpdateSynonymsResultStatus.UPDATED;
426426

427-
maybeReloadAnalyzers(synonymsSetId, refresh, false, updateStatus, l2);
427+
checkIndexSearchableAndReloadAnalyzers(synonymsSetId, refresh, false, updateStatus, l2);
428428
}));
429429
}
430430

@@ -468,7 +468,11 @@ public void deleteSynonymRule(
468468
return;
469469
}
470470

471-
maybeReloadAnalyzers(synonymsSetId, refresh, false, UpdateSynonymsResultStatus.DELETED, listener);
471+
if (refresh) {
472+
reloadAnalyzers(synonymsSetId, false, UpdateSynonymsResultStatus.DELETED, listener);
473+
} else {
474+
listener.onResponse(new SynonymsReloadResult(UpdateSynonymsResultStatus.DELETED, null));
475+
}
472476
}));
473477
}
474478

@@ -526,7 +530,7 @@ private void deleteSynonymsSetObjects(String synonymSetId, ActionListener<BulkBy
526530
public void deleteSynonymsSet(String synonymSetId, ActionListener<AcknowledgedResponse> listener) {
527531

528532
// Previews reloading the resource to understand its usage on indices
529-
maybeReloadAnalyzers(synonymSetId, true, true, null, listener.delegateFailure((reloadListener, reloadResult) -> {
533+
reloadAnalyzers(synonymSetId, true, null, listener.delegateFailure((reloadListener, reloadResult) -> {
530534
Map<String, ReloadAnalyzersResponse.ReloadDetails> reloadDetails = reloadResult.reloadAnalyzersResponse.getReloadDetails();
531535
if (reloadDetails.isEmpty() == false) {
532536
Set<String> indices = reloadDetails.entrySet()
@@ -566,7 +570,7 @@ public void deleteSynonymsSet(String synonymSetId, ActionListener<AcknowledgedRe
566570
}));
567571
}
568572

569-
private <T> void maybeReloadAnalyzers(
573+
private <T> void checkIndexSearchableAndReloadAnalyzers(
570574
String synonymSetId,
571575
boolean refresh,
572576
boolean preview,
@@ -596,16 +600,20 @@ private <T> void maybeReloadAnalyzers(
596600
return;
597601
}
598602

599-
// auto-reload all reloadable analyzers (currently only those that use updateable synonym or keyword_marker filters)
600-
ReloadAnalyzersRequest reloadAnalyzersRequest = new ReloadAnalyzersRequest(synonymSetId, preview, "*");
601-
client.execute(
602-
TransportReloadAnalyzersAction.TYPE,
603-
reloadAnalyzersRequest,
604-
listener.safeMap(reloadResponse -> new SynonymsReloadResult(synonymsOperationResult, reloadResponse))
605-
);
603+
reloadAnalyzers(synonymSetId, preview, synonymsOperationResult, listener);
606604
}));
607605
}
608606

607+
private void reloadAnalyzers(String synonymSetId, boolean preview, UpdateSynonymsResultStatus synonymsOperationResult, ActionListener<SynonymsReloadResult> listener) {
608+
// auto-reload all reloadable analyzers (currently only those that use updateable synonym or keyword_marker filters)
609+
ReloadAnalyzersRequest reloadAnalyzersRequest = new ReloadAnalyzersRequest(synonymSetId, preview, "*");
610+
client.execute(
611+
TransportReloadAnalyzersAction.TYPE,
612+
reloadAnalyzersRequest,
613+
listener.safeMap(reloadResponse -> new SynonymsReloadResult(synonymsOperationResult, reloadResponse))
614+
);
615+
}
616+
609617
// Allows checking failures in tests
610618
void checkSynonymsIndexHealth(ActionListener<ClusterHealthResponse> listener) {
611619
ClusterHealthRequest healthRequest = new ClusterHealthRequest(

0 commit comments

Comments
 (0)