diff --git a/server/src/test/java/org/elasticsearch/transport/ConnectionManagerTests.java b/server/src/test/java/org/elasticsearch/transport/ConnectionManagerTests.java index f34d39ae7252a..37c0d92612fdc 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 void onNodeDisconnected(DiscoveryNode node, Transport.Connection connecti 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);