Skip to content

Commit fa2ceb4

Browse files
authored
Add @FixForMultiProject in EnrichPolicyMaintenanceService (#132676)
As a reminder that we need to ensure the enrich indices are cleaned up for all projects.
1 parent dcff4d3 commit fa2ceb4

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

x-pack/plugin/enrich/src/main/java/org/elasticsearch/xpack/enrich/EnrichPolicyMaintenanceService.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -24,6 +24,7 @@
2424
import org.elasticsearch.common.component.LifecycleListener;
2525
import org.elasticsearch.common.settings.Settings;
2626
import org.elasticsearch.common.util.concurrent.EsRejectedExecutionException;
27+
import org.elasticsearch.core.FixForMultiProject;
2728
import org.elasticsearch.core.TimeValue;
2829
import org.elasticsearch.index.Index;
2930
import org.elasticsearch.threadpool.Scheduler;
@@ -145,6 +146,7 @@ void concludeMaintenance() {
145146
maintenanceLock.release();
146147
}
147148

149+
@FixForMultiProject // We need to ensure that the enrich indices are cleaned up for all projects
148150
void cleanUpEnrichIndices() {
149151
// Get cluster state first because for a new index to exist there then it has to have already been added to the inflight list
150152
// If the new index is in the cluster state but not in the inflight list, then that means that the index name was removed from the

0 commit comments

Comments
 (0)