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 ccb4832f0765d8..627361edaf9410 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 @@ 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");