We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 8ad414b commit 62bdc83Copy full SHA for 62bdc83
server/src/main/java/org/elasticsearch/cluster/routing/allocation/WriteLoadConstraintMonitor.java
@@ -81,6 +81,7 @@ public void onNewInfo(ClusterInfo clusterInfo) {
81
clusterInfo.getNodeUsageStatsForThreadPools().forEach((nodeId, usageStats) -> {
82
final NodeUsageStatsForThreadPools.ThreadPoolUsageStats writeThreadPoolStats = usageStats.threadPoolUsageStatsMap()
83
.get(ThreadPool.Names.WRITE);
84
+ assert writeThreadPoolStats != null : "Write thread pool is not publishing usage stats for node [" + nodeId + "]";
85
if (writeThreadPoolStats.maxThreadPoolQueueLatencyMillis() > writeLoadConstraintSettings.getQueueLatencyThreshold().millis()) {
86
nodeIdsExceedingLatencyThreshold.add(nodeId);
87
}
0 commit comments