diff --git a/muted-tests.yml b/muted-tests.yml index a4094a5bb6bc8..2f548f290eeae 100644 --- a/muted-tests.yml +++ b/muted-tests.yml @@ -272,9 +272,6 @@ tests: - class: org.elasticsearch.search.CCSDuelIT method: testTerminateAfter issue: https://github.com/elastic/elasticsearch/issues/126085 -- class: org.elasticsearch.search.basic.SearchWithRandomDisconnectsIT - method: testSearchWithRandomDisconnects - issue: https://github.com/elastic/elasticsearch/issues/122707 - class: org.elasticsearch.packaging.test.DockerTests method: test020PluginsListWithNoPlugins issue: https://github.com/elastic/elasticsearch/issues/126232 diff --git a/server/src/internalClusterTest/java/org/elasticsearch/search/basic/SearchWithRandomDisconnectsIT.java b/server/src/internalClusterTest/java/org/elasticsearch/search/basic/SearchWithRandomDisconnectsIT.java index d230063162f5f..9384a3e243885 100644 --- a/server/src/internalClusterTest/java/org/elasticsearch/search/basic/SearchWithRandomDisconnectsIT.java +++ b/server/src/internalClusterTest/java/org/elasticsearch/search/basic/SearchWithRandomDisconnectsIT.java @@ -82,7 +82,7 @@ private void runMoreSearches() { } }); } - for (int i = 0, n = randomIntBetween(50, 100); i < n; i++) { + for (int i = 0, n = randomIntBetween(5, 10); i < n; i++) { NetworkDisruption networkDisruption = new NetworkDisruption( isolateNode(internalCluster().getRandomNodeName()), NetworkDisruption.DISCONNECT @@ -90,6 +90,13 @@ private void runMoreSearches() { setDisruptionScheme(networkDisruption); networkDisruption.startDisrupting(); networkDisruption.stopDisrupting(); + + try { + Thread.sleep(300); + } catch (InterruptedException e) { + Thread.currentThread().interrupt(); + } + internalCluster().clearDisruptionScheme(); ensureFullyConnectedCluster(); } @@ -103,7 +110,7 @@ private void runMoreSearches() { private static SearchRequestBuilder prepareRandomSearch() { return prepareSearch("*").setQuery(new MatchAllQueryBuilder()) - .setSize(9999) + .setSize(randomIntBetween(10, 100)) .setFetchSource(true) .setAllowPartialSearchResults(randomBoolean()); }