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

Core: Make sure that the queue size is set on the alert thread pools 

Also removed hack leftover.

Original commit: elastic/x-pack-elasticsearch@44fd070f5d
This commit is contained in:
Martijn van Groningen 2015-03-18 16:40:22 -07:00
parent 2377d1525b
commit 5dfe02ec64
1 changed files with 4 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
src/main/java/org/elasticsearch/alerts/AlertsPlugin.java
View File

@ -58,25 +58,11 @@ public class AlertsPlugin extends AbstractPlugin {
return settingsBuilder()
.put("threadpool." + SCHEDULER_THREAD_POOL_NAME + ".type", "fixed")
.put("threadpool." + SCHEDULER_THREAD_POOL_NAME + ".size", availableProcessors * 2)
.put(alertThreadPoolSettings(availableProcessors, null))
.put("threadpool." + SCHEDULER_THREAD_POOL_NAME + ".queue_size", 1000)
.put("threadpool." + NAME + ".type", "fixed")
.put("threadpool." + NAME + ".size", availableProcessors * 5)
.put("threadpool." + NAME + ".queue_size", 1000)
.build();
}
public static Settings alertThreadPoolSettings(int availableProcessors, Integer queueSize) {
// Executing an alert involves a lot of wait time for networking (search, several index requests + optional condition logic)
//TODO Hack to get around threadpool issue
if (queueSize != null) {
return settingsBuilder()
.put("threadpool." + NAME + ".type", "fixed")
.put("threadpool." + NAME + ".size", availableProcessors * 5)
.put("threadpool." + NAME + ".queue_size", queueSize)
.build();
} else {
return settingsBuilder()
.put("threadpool." + NAME + ".type", "fixed")
.put("threadpool." + NAME + ".size", availableProcessors * 5)
.build();
}
}
}