[FLINK-31897][tests] Fix the unstable test ClientTest#testRequestUnav…

…ailableHost
pppsunil · Apr 25, 2023 · 918b873 · 918b873
1 parent caf5c10
commit 918b873
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/...yable-state-runtime/src/test/java/org/apache/flink/queryablestate/network/ClientTest.java b/...yable-state-runtime/src/test/java/org/apache/flink/queryablestate/network/ClientTest.java
@@ -230,7 +230,7 @@ void testSimpleRequests() throws Exception {
 
     /** Tests that a request to an unavailable host is failed with ConnectException. */
     @Test
-    void testRequestUnavailableHost() throws Exception {
+    void testRequestUnavailableHost() {
         AtomicKvStateRequestStats stats = new AtomicKvStateRequestStats();
 
         MessageSerializer<KvStateInternalRequest, KvStateResponse> serializer =
@@ -243,7 +243,10 @@ void testRequestUnavailableHost() throws Exception {
         try {
             client = new Client<>("Test Client", 1, serializer, stats);
 
-            InetSocketAddress serverAddress = new InetSocketAddress(InetAddress.getLocalHost(), 0);
+            // Since no real servers are created based on the server address, the given fixed port
+            // is enough.
+            InetSocketAddress serverAddress =
+                    new InetSocketAddress("flink-qs-client-test-unavailable-host", 12345);
 
             KvStateInternalRequest request =
                     new KvStateInternalRequest(new KvStateID(), new byte[0]);