diff --git a/elasticsearch/src/test/java/org/elasticsearch/xpack/monitoring/resolver/node/NodeStatsTests.java b/elasticsearch/src/test/java/org/elasticsearch/xpack/monitoring/resolver/node/NodeStatsTests.java index 814247b27af..09bb88500a8 100644 --- a/elasticsearch/src/test/java/org/elasticsearch/xpack/monitoring/resolver/node/NodeStatsTests.java +++ b/elasticsearch/src/test/java/org/elasticsearch/xpack/monitoring/resolver/node/NodeStatsTests.java @@ -45,7 +45,6 @@ public class NodeStatsTests extends MonitoringIntegTestCase { } public void testNodeStats() throws Exception { - logger.debug("--> creating some indices for future node stats"); final int numDocs = between(50, 150); for (int i = 0; i < numDocs; i++) { client().prepareIndex("test", "foo").setSource("value", randomInt()).get(); @@ -59,32 +58,27 @@ public class NodeStatsTests extends MonitoringIntegTestCase { awaitMonitoringDocsCount(greaterThan(0L), NodeStatsResolver.TYPE); - logger.debug("--> searching for monitoring documents of type [{}]", NodeStatsResolver.TYPE); SearchResponse response = client().prepareSearch().setTypes(NodeStatsResolver.TYPE).get(); assertThat(response.getHits().getTotalHits(), greaterThan(0L)); - logger.debug("--> checking that every document contains the expected fields"); - for (SearchHit searchHit : response.getHits().getHits()) { Map fields = searchHit.sourceAsMap(); for (String filter : nodeStatsFilters(watcherEnabled)) { if (Constants.WINDOWS) { // load average is unavailable on Windows - if ("node_stats.os.cpu.load_average.1m".equals(filter)) { + if (filter.startsWith("node_stats.os.cpu.load_average")) { continue; } } - if (filter.startsWith("node_stats.fs")) { - // NORELEASE what is going on here? + // fs stats and cgroup stats are not reported on every node + if (filter.startsWith("node_stats.fs") || filter.startsWith("node_stats.os.cgroup")) { continue; } assertContains(filter, fields); } } - - logger.debug("--> node stats successfully collected"); } /**