[flink] 02/02: [FLINK-31897][tests] Fix the unstable test ClientTest#testRequestUnavailableHost

[chesnay]

This is an automated email from the ASF dual-hosted git repository.

chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git

commit 918b873c0c0654b029140581c0ed49b44f9c5273
Author: Yuxin Tan <tanyuxinw...@gmail.com>
AuthorDate: Mon Apr 24 22:59:24 2023 +0800

    [FLINK-31897][tests] Fix the unstable test 
ClientTest#testRequestUnavailableHost
---
 .../java/org/apache/flink/queryablestate/network/ClientTest.java   | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git 
a/flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/network/ClientTest.java
 
b/flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/network/ClientTest.java
index d14bb75015f..e2f93b755b4 100644
--- 
a/flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/network/ClientTest.java
+++ 
b/flink-queryable-state/flink-queryable-state-runtime/src/test/java/org/apache/flink/queryablestate/network/ClientTest.java
@@ -230,7 +230,7 @@ class ClientTest {
 
     /** 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 @@ class ClientTest {
         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]);