(flink) branch master updated: [FLINK-35246][test] Fix incorrect address construction in SqlClientSSLTest

[guoweijie]

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

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


The following commit(s) were added to refs/heads/master by this push:
     new 4e6dbe2d1a2 [FLINK-35246][test] Fix incorrect address construction in 
SqlClientSSLTest
4e6dbe2d1a2 is described below

commit 4e6dbe2d1a225a0d0e48fd0997c1f11317402e42
Author: Weijie Guo <res...@163.com>
AuthorDate: Fri Apr 26 16:59:49 2024 +0800

    [FLINK-35246][test] Fix incorrect address construction in SqlClientSSLTest
---
 .../java/org/apache/flink/table/client/SqlClientSSLTest.java     | 9 ++++-----
 1 file changed, 4 insertions(+), 5 deletions(-)

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 ccb4832f076..627361edaf9 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.Test;
 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 @@ class SqlClientSSLTest extends SqlClientTestBase {
                 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");