[FLINK-35246][test] Fix incorrect address construction in SqlClientSS…

…LTest
apache · Apr 26, 2024 · 4e6dbe2 · 4e6dbe2
1 parent 3ff2ba4
commit 4e6dbe2
Showing 1 changed file with 4 additions and 5 deletions.
diff --git a/...-table/flink-sql-client/src/test/java/org/apache/flink/table/client/SqlClientSSLTest.java b/...-table/flink-sql-client/src/test/java/org/apache/flink/table/client/SqlClientSSLTest.java
@@ -28,7 +28,6 @@
 import org.junit.jupiter.api.extension.RegisterExtension;
 
 import java.io.IOException;
-import java.net.InetSocketAddress;
 import java.net.URL;
 import java.nio.file.Files;
 import java.nio.file.Path;
@@ -66,10 +65,10 @@ void testGatewayMode() throws Exception {
                 new String[] {
                     "gateway",
                     "-e",
-                    InetSocketAddress.createUnresolved(
-                                    SQL_GATEWAY_REST_ENDPOINT_EXTENSION.getTargetAddress(),
-                                    SQL_GATEWAY_REST_ENDPOINT_EXTENSION.getTargetPort())
-                            .toString()
+                    String.format(
+                            "%s:%d",
+                            SQL_GATEWAY_REST_ENDPOINT_EXTENSION.getTargetAddress(),
+                            SQL_GATEWAY_REST_ENDPOINT_EXTENSION.getTargetPort())
                 };
         String actual = runSqlClient(args, String.join("\n", "SET;", "QUIT;"), false);
         assertThat(actual).contains(SecurityOptions.SSL_REST_ENABLED.key(), "true");