diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/net/ConnectionUtilsTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/net/ConnectionUtilsTest.java index 22655ec274ac1..401b3ef06dbca 100644 --- a/flink-runtime/src/test/java/org/apache/flink/runtime/net/ConnectionUtilsTest.java +++ b/flink-runtime/src/test/java/org/apache/flink/runtime/net/ConnectionUtilsTest.java @@ -73,7 +73,7 @@ public void testFindConnectingAddressWhenGetLocalHostThrows() throws Exception { Thread socketServerThread; try (ServerSocket socket = new ServerSocket(0, 1, loopbackAddress)) { // Make sure that the thread will eventually die even if something else goes wrong - socket.setSoTimeout(10_000); + socket.setSoTimeout(0); socketServerThread = new Thread( new Runnable() {