diff --git a/common/network-common/src/test/java/org/apache/spark/network/TransportClientFactorySuite.java b/common/network-common/src/test/java/org/apache/spark/network/TransportClientFactorySuite.java index 2c621140db83..b4caa872928d 100644 --- a/common/network-common/src/test/java/org/apache/spark/network/TransportClientFactorySuite.java +++ b/common/network-common/src/test/java/org/apache/spark/network/TransportClientFactorySuite.java @@ -117,7 +117,7 @@ private void testClientReuse(int maxConnections, boolean concurrent) } Assert.assertEquals(0, failed.get()); - Assert.assertEquals(clients.size(), maxConnections); + Assert.assertTrue(clients.size() <= maxConnections); for (TransportClient client : clients) { client.close();