diff --git a/muted-tests.yml b/muted-tests.yml index 2042b7199fc45..74a91a35a4461 100644 --- a/muted-tests.yml +++ b/muted-tests.yml @@ -440,9 +440,6 @@ tests: - class: org.elasticsearch.xpack.search.CrossClusterAsyncSearchIT method: testCancelViaExpirationOnRemoteResultsWithMinimizeRoundtrips issue: https://github.com/elastic/elasticsearch/issues/127302 -- class: org.elasticsearch.xpack.search.CrossClusterAsyncSearchIT - method: testCancellationViaTimeoutWithAllowPartialResultsSetToFalse - issue: https://github.com/elastic/elasticsearch/issues/131248 - class: org.elasticsearch.xpack.kql.parser.KqlParserBooleanQueryTests method: testParseAndQuery issue: https://github.com/elastic/elasticsearch/issues/133871 diff --git a/x-pack/plugin/async-search/src/internalClusterTest/java/org/elasticsearch/xpack/search/CrossClusterAsyncSearchIT.java b/x-pack/plugin/async-search/src/internalClusterTest/java/org/elasticsearch/xpack/search/CrossClusterAsyncSearchIT.java index 7cc43d43c6ff5..dfe877695a646 100644 --- a/x-pack/plugin/async-search/src/internalClusterTest/java/org/elasticsearch/xpack/search/CrossClusterAsyncSearchIT.java +++ b/x-pack/plugin/async-search/src/internalClusterTest/java/org/elasticsearch/xpack/search/CrossClusterAsyncSearchIT.java @@ -1752,6 +1752,7 @@ public void testCancellationViaTimeoutWithAllowPartialResultsSetToFalse() throws String remoteIndex = (String) testClusterInfo.get("remote.index"); SearchListenerPlugin.blockLocalQueryPhase(); + SearchListenerPlugin.blockRemoteQueryPhase(); TimeValue searchTimeout = new TimeValue(100, TimeUnit.MILLISECONDS); // query builder that will sleep for the specified amount of time in the query phase @@ -1810,6 +1811,7 @@ public void testCancellationViaTimeoutWithAllowPartialResultsSetToFalse() throws } finally { SearchListenerPlugin.allowLocalQueryPhase(); + SearchListenerPlugin.allowRemoteQueryPhase(); } // query phase has begun, so wait for query failure (due to timeout)