commit 4e6dbe2d1a225a0d0e48fd0997c1f11317402e42
author Weijie Guo <reswqa@163.com> Fri Apr 26 16:59:49 2024 +0800
committer Weijie Guo <reswqa@163.com> Fri Apr 26 21:16:58 2024 +0800
tree 029134fde900b0b7c59b74ca7e05be19cd43cc3c
parent 3ff2ba43720e72d050b3cc1aac35db02698340e6

[FLINK-35246][test] Fix incorrect address construction in SqlClientSSLTest

flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/SqlClientSSLTest.java

diff --git a/flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/SqlClientSSLTest.java b/flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/SqlClientSSLTest.java
index ccb4832..627361e 100644
--- a/flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/SqlClientSSLTest.java
+++ b/flink-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 @@
                 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");