[flink] branch master updated: [FLINK-31911][sql][tests] Fix address address construction

[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


The following commit(s) were added to refs/heads/master by this push:
     new 146847e53f1 [FLINK-31911][sql][tests] Fix address address construction
146847e53f1 is described below

commit 146847e53f10967dc2133cfdee6adbc57bccdd38
Author: Chesnay Schepler <ches...@apache.org>
AuthorDate: Thu Apr 27 14:17:10 2023 +0200

    [FLINK-31911][sql][tests] Fix address address construction
---
 .../test/java/org/apache/flink/table/client/SqlClientTest.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/SqlClientTest.java
 
b/flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/SqlClientTest.java
index e107b73b1ac..e729c111a65 100644
--- 
a/flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/SqlClientTest.java
+++ 
b/flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/SqlClientTest.java
@@ -40,7 +40,6 @@ import java.io.ByteArrayOutputStream;
 import java.io.File;
 import java.io.IOException;
 import java.io.OutputStream;
-import java.net.InetSocketAddress;
 import java.net.URL;
 import java.nio.charset.StandardCharsets;
 import java.nio.file.Files;
@@ -148,10 +147,10 @@ class SqlClientTest {
                 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("execution.target", "yarn-session");