Skip to content

Commit 8ba07e0

Browse files
committed
Merge remote-tracking branch 'origin/manage_ad_state_indices' into manage_ad_state_indices
2 parents f6ac275 + e95a85a commit 8ba07e0

File tree

2 files changed

+6
-2
lines changed

2 files changed

+6
-2
lines changed

docs/changelog/137603.yaml

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,5 @@
1+
pr: 137603
2+
summary: Add daily task to manage .ml-state indices
3+
area: Machine Learning
4+
type: enhancement
5+
issues: []

x-pack/plugin/ml/src/main/java/org/elasticsearch/xpack/ml/MlDailyMaintenanceService.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -569,14 +569,14 @@ private void triggerJobsInStateWithoutMatchingTask(
569569
}
570570
chainTaskExecutor.execute(jobsActionListener);
571571
}, finalListener::onFailure);
572-
573572
ActionListener<GetJobsAction.Response> getJobsActionListener = ActionListener.wrap(getJobsResponse -> {
574573
Set<String> jobsInState = getJobsResponse.getResponse().results().stream().filter(jobFilter).map(Job::getId).collect(toSet());
575574
if (jobsInState.isEmpty()) {
576575
finalListener.onResponse(AcknowledgedResponse.TRUE);
577576
return;
578577
}
579578
jobsInStateHolder.set(jobsInState);
579+
580580
executeAsyncWithOrigin(
581581
client,
582582
ML_ORIGIN,
@@ -585,7 +585,6 @@ private void triggerJobsInStateWithoutMatchingTask(
585585
listTasksActionListener
586586
);
587587
}, finalListener::onFailure);
588-
589588
executeAsyncWithOrigin(client, ML_ORIGIN, GetJobsAction.INSTANCE, new GetJobsAction.Request("*"), getJobsActionListener);
590589
}
591590

0 commit comments

Comments
 (0)