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

[ML] Set ml' tp queue sizes to a reasonable level. 

Original commit: elastic/x-pack-elasticsearch@7f7b2defcd
This commit is contained in:
Martijn van Groningen 2017-03-21 13:09:39 +01:00
parent 62721c78ea
commit 4f5b3dfea3
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
plugin/src/main/java/org/elasticsearch/xpack/ml/MachineLearning.java
View File

@ -429,12 +429,12 @@ public class MachineLearning implements ActionPlugin {
// fail quick to run autodetect process / datafeed, so no queues
// 4 threads: for c++ logging, result processing, state processing and restore state
FixedExecutorBuilder autoDetect = new FixedExecutorBuilder(settings, AUTODETECT_PROCESS_THREAD_POOL_NAME,
maxNumberOfJobs * 4, 4, "xpack.ml.autodetect_process_thread_pool");
maxNumberOfJobs * 4, 200, "xpack.ml.autodetect_process_thread_pool");
// TODO: if datafeed and non datafeed jobs are considered more equal and the datafeed and
// autodetect process are created at the same time then these two different TPs can merge.
FixedExecutorBuilder datafeed = new FixedExecutorBuilder(settings, DATAFEED_RUNNER_THREAD_POOL_NAME,
maxNumberOfJobs, 1, "xpack.ml.datafeed_thread_pool");
maxNumberOfJobs, 200, "xpack.ml.datafeed_thread_pool");
return Arrays.asList(ml, autoDetect, datafeed);
}
}