(flink) branch master updated: [FLINK-33418][test] Uses getHost()

[mapohl]

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

mapohl 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 f6f785fd1a9 [FLINK-33418][test] Uses getHost()
f6f785fd1a9 is described below

commit f6f785fd1a927ade00f91bf0de0f96a2268aa4e5
Author: Matthias Pohl <matthias.p...@aiven.io>
AuthorDate: Wed Nov 1 18:08:23 2023 +0100

    [FLINK-33418][test] Uses getHost()
---
 .../java/org/apache/flink/tests/hive/containers/HiveContainers.java   | 4 ++--
 .../java/org/apache/flink/table/gateway/containers/HiveContainer.java | 3 ++-
 2 files changed, 4 insertions(+), 3 deletions(-)

diff --git 
a/flink-end-to-end-tests/flink-end-to-end-tests-hive/src/test/java/org/apache/flink/tests/hive/containers/HiveContainers.java
 
b/flink-end-to-end-tests/flink-end-to-end-tests-hive/src/test/java/org/apache/flink/tests/hive/containers/HiveContainers.java
index 829612d31dc..74d3692216c 100644
--- 
a/flink-end-to-end-tests/flink-end-to-end-tests-hive/src/test/java/org/apache/flink/tests/hive/containers/HiveContainers.java
+++ 
b/flink-end-to-end-tests/flink-end-to-end-tests-hive/src/test/java/org/apache/flink/tests/hive/containers/HiveContainers.java
@@ -99,8 +99,8 @@ public class HiveContainers {
                             .post(new FormBody.Builder().build())
                             .url(
                                     String.format(
-                                            "http://127.0.0.1:%s";,
-                                            
getMappedPort(getNameNodeWebEndpointPort())))
+                                            "http://%s:%s";,
+                                            getHost(), 
getMappedPort(getNameNodeWebEndpointPort())))
                             .build();
             OkHttpClient client = new OkHttpClient();
             try (Response response = client.newCall(request).execute()) {
diff --git 
a/flink-end-to-end-tests/flink-sql-gateway-test/src/test/java/org/apache/flink/table/gateway/containers/HiveContainer.java
 
b/flink-end-to-end-tests/flink-sql-gateway-test/src/test/java/org/apache/flink/table/gateway/containers/HiveContainer.java
index cb44cd4e517..6fa9064fcfd 100644
--- 
a/flink-end-to-end-tests/flink-sql-gateway-test/src/test/java/org/apache/flink/table/gateway/containers/HiveContainer.java
+++ 
b/flink-end-to-end-tests/flink-sql-gateway-test/src/test/java/org/apache/flink/table/gateway/containers/HiveContainer.java
@@ -80,7 +80,8 @@ public class HiveContainer extends 
GenericContainer<HiveContainer> {
                         .post(new FormBody.Builder().build())
                         .url(
                                 String.format(
-                                        "http://127.0.0.1:%s";, 
getMappedPort(NAME_NODE_WEB_PORT)))
+                                        "http://%s:%s";,
+                                        getHost(), 
getMappedPort(NAME_NODE_WEB_PORT)))
                         .build();
         OkHttpClient client = new OkHttpClient();
         try (Response response = client.newCall(request).execute()) {