honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

[ML] Use the internal client for DeleteModelSnapshotAction (elastic/x-pack-elasticsearch#2407) 

Original commit: elastic/x-pack-elasticsearch@7d3cbfa0cf
This commit is contained in:
David Kyle 2017-08-31 17:49:08 +01:00
parent 7b13c4adc0
commit 6ba02e8087
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
plugin/src/main/java/org/elasticsearch/xpack/ml/action/DeleteModelSnapshotAction.java
View File

@ -33,6 +33,7 @@ import org.elasticsearch.xpack.ml.job.persistence.JobProvider;
import org.elasticsearch.xpack.ml.job.process.autodetect.state.ModelSnapshot; import org.elasticsearch.xpack.ml.job.process.autodetect.state.ModelSnapshot;
import org.elasticsearch.xpack.ml.notifications.Auditor; import org.elasticsearch.xpack.ml.notifications.Auditor;
import org.elasticsearch.xpack.ml.utils.ExceptionsHelper; import org.elasticsearch.xpack.ml.utils.ExceptionsHelper;
import org.elasticsearch.xpack.security.InternalClient;
import java.io.IOException; import java.io.IOException;
import java.util.Collections; import java.util.Collections;
@ -130,7 +131,7 @@ public class DeleteModelSnapshotAction extends Action<DeleteModelSnapshotAction.
public static class TransportAction extends HandledTransportAction<Request, Response> { public static class TransportAction extends HandledTransportAction<Request, Response> {
private final Client client; private final InternalClient client;
private final JobProvider jobProvider; private final JobProvider jobProvider;
private final JobManager jobManager; private final JobManager jobManager;
private final ClusterService clusterService; private final ClusterService clusterService;
@ -140,7 +141,7 @@ public class DeleteModelSnapshotAction extends Action<DeleteModelSnapshotAction.
public TransportAction(Settings settings, TransportService transportService, ThreadPool threadPool, public TransportAction(Settings settings, TransportService transportService, ThreadPool threadPool,
ActionFilters actionFilters, IndexNameExpressionResolver indexNameExpressionResolver, ActionFilters actionFilters, IndexNameExpressionResolver indexNameExpressionResolver,
JobProvider jobProvider, JobManager jobManager, ClusterService clusterService, JobProvider jobProvider, JobManager jobManager, ClusterService clusterService,
Client client, Auditor auditor) { InternalClient client, Auditor auditor) {
super(settings, NAME, threadPool, transportService, actionFilters, indexNameExpressionResolver, Request::new); super(settings, NAME, threadPool, transportService, actionFilters, indexNameExpressionResolver, Request::new);
this.client = client; this.client = client;
this.jobProvider = jobProvider; this.jobProvider = jobProvider;