diff --git a/server/src/test/java/org/elasticsearch/action/search/SearchAsyncActionTests.java b/server/src/test/java/org/elasticsearch/action/search/SearchAsyncActionTests.java index 2726de23758..ace92159639 100644 --- a/server/src/test/java/org/elasticsearch/action/search/SearchAsyncActionTests.java +++ b/server/src/test/java/org/elasticsearch/action/search/SearchAsyncActionTests.java @@ -256,7 +256,6 @@ public class SearchAsyncActionTests extends ESTestCase { assertEquals(10, numRequests.get()); } - @AwaitsFix(bugUrl = "https://github.com/elastic/elasticsearch/issues/29242") public void testFanOutAndCollect() throws InterruptedException { SearchRequest request = new SearchRequest(); request.allowPartialSearchResults(true); @@ -347,6 +346,9 @@ public class SearchAsyncActionTests extends ESTestCase { sendReleaseSearchContext(result.getRequestId(), new MockConnection(result.node), OriginalIndices.NONE); } responseListener.onResponse(response); + if (latch.getCount() == 0) { + throw new AssertionError("Running a search phase after the latch has reached 0 !!!!"); + } latch.countDown(); } };