This is an automated email from the ASF dual-hosted git repository. mapohl pushed a commit to branch release-1.18 in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.18 by this push: new e9548a6d420 [FLINK-33418][test] Uses getHost() e9548a6d420 is described below commit e9548a6d420ed97e0b3d50523092a6663d624ab4 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()) {