Skip to content

Commit d493e3d

Browse files
author
Hendrik Muhs
committed
fix transport client mode
1 parent fffa471 commit d493e3d

File tree

2 files changed

+6
-2
lines changed

2 files changed

+6
-2
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,6 @@
3030
import org.elasticsearch.xpack.core.ml.datafeed.DatafeedState;
3131
import org.elasticsearch.xpack.core.ml.job.config.Job;
3232
import org.elasticsearch.xpack.core.ml.job.config.JobState;
33-
import org.elasticsearch.xpack.ml.job.JobManager;
3433
import org.elasticsearch.xpack.ml.job.JobManagerHolder;
3534
import org.elasticsearch.xpack.ml.process.NativeController;
3635
import org.elasticsearch.xpack.ml.process.NativeControllerHolder;
@@ -175,7 +174,8 @@ public Retriever(Client client, JobManagerHolder jobManagerHolder, boolean avail
175174
}
176175

177176
public void execute(ActionListener<Usage> listener) {
178-
if (enabled == false) {
177+
// empty holder means either ML disabled or transport client mode
178+
if (jobManagerHolder.isEmpty()) {
179179
listener.onResponse(
180180
new MachineLearningFeatureSetUsage(available, enabled, Collections.emptyMap(), Collections.emptyMap(), 0));
181181
return;

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

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -27,6 +27,10 @@ public JobManagerHolder(JobManager jobManager) {
2727
this.instance = jobManager;
2828
}
2929

30+
public boolean isEmpty() {
31+
return instance == null;
32+
}
33+
3034
/**
3135
* Get the instance of the held JobManager.
3236
*

0 commit comments

Comments
 (0)