File tree Expand file tree Collapse file tree 1 file changed +2
-0
lines changed
x-pack/plugin/enrich/src/main/java/org/elasticsearch/xpack/enrich Expand file tree Collapse file tree 1 file changed +2
-0
lines changed Original file line number Diff line number Diff line change 2424import org .elasticsearch .common .component .LifecycleListener ;
2525import org .elasticsearch .common .settings .Settings ;
2626import org .elasticsearch .common .util .concurrent .EsRejectedExecutionException ;
27+ import org .elasticsearch .core .FixForMultiProject ;
2728import org .elasticsearch .core .TimeValue ;
2829import org .elasticsearch .index .Index ;
2930import 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
You can’t perform that action at this time.
0 commit comments