diff --git a/server/src/test/java/org/elasticsearch/transport/ConnectionManagerTests.java b/server/src/test/java/org/elasticsearch/transport/ConnectionManagerTests.java index f34d39ae725..37c0d92612f 100644 --- a/server/src/test/java/org/elasticsearch/transport/ConnectionManagerTests.java +++ b/server/src/test/java/org/elasticsearch/transport/ConnectionManagerTests.java @@ -124,6 +124,7 @@ public class ConnectionManagerTests extends ESTestCase { assertEquals(1, nodeDisconnectedCount.get()); } + @AwaitsFix(bugUrl = "https://github.com/elastic/elasticsearch/issues/49903") public void testConcurrentConnectsAndDisconnects() throws BrokenBarrierException, InterruptedException { DiscoveryNode node = new DiscoveryNode("", new TransportAddress(InetAddress.getLoopbackAddress(), 0), Version.CURRENT); Transport.Connection connection = new TestConnect(node);