Skip to content

Commit e843469

Browse files
authored
Unmute smoke test monitoring with watcher. (#51490)
1 parent 0e47311 commit e843469

File tree

2 files changed

+8
-5
lines changed

2 files changed

+8
-5
lines changed

x-pack/qa/smoke-test-monitoring-with-watcher/build.gradle

+3
Original file line numberDiff line numberDiff line change
@@ -8,8 +8,11 @@ dependencies {
88

99
testClusters.integTest {
1010
testDistribution = 'DEFAULT'
11+
setting 'xpack.slm.enabled', 'false'
1112
setting 'xpack.ilm.enabled', 'false'
1213
setting 'xpack.monitoring.enabled', 'true'
14+
setting 'xpack.monitoring.collection.enabled', 'true'
15+
setting 'xpack.monitoring.collection.interval', '1s'
1316
setting 'xpack.watcher.enabled', 'true'
1417
setting 'xpack.security.enabled', 'false'
1518
setting 'xpack.ml.enabled', 'false'

x-pack/qa/smoke-test-monitoring-with-watcher/src/test/java/org/elasticsearch/smoketest/MonitoringWithWatcherRestIT.java

+5-5
Original file line numberDiff line numberDiff line change
@@ -5,7 +5,6 @@
55
*/
66
package org.elasticsearch.smoketest;
77

8-
import org.apache.lucene.util.LuceneTestCase.AwaitsFix;
98
import org.elasticsearch.client.Request;
109
import org.elasticsearch.client.Response;
1110
import org.elasticsearch.common.Strings;
@@ -18,7 +17,6 @@
1817
import static org.elasticsearch.common.xcontent.XContentFactory.jsonBuilder;
1918
import static org.hamcrest.Matchers.is;
2019

21-
@AwaitsFix(bugUrl = "flaky tests")
2220
public class MonitoringWithWatcherRestIT extends ESRestTestCase {
2321

2422
/**
@@ -79,9 +77,11 @@ public void testThatHttpExporterAddsWatches() throws Exception {
7977
}
8078

8179
private void assertMonitoringWatchHasBeenOverWritten(String watchId) throws Exception {
82-
ObjectPath path = ObjectPath.createFromResponse(client().performRequest(new Request("GET", "/_watcher/watch/" + watchId)));
83-
String interval = path.evaluate("watch.trigger.schedule.interval");
84-
assertThat(interval, is("1m"));
80+
assertBusy(() -> {
81+
ObjectPath path = ObjectPath.createFromResponse(client().performRequest(new Request("GET", "/_watcher/watch/" + watchId)));
82+
String interval = path.evaluate("watch.trigger.schedule.interval");
83+
assertThat(interval, is("1m"));
84+
});
8585
}
8686

8787
private void assertTotalWatchCount(int expectedWatches) throws Exception {

0 commit comments

Comments
 (0)