You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ma...@apache.org on 2023/11/27 09:29:59 UTC
(flink) branch release-1.18 updated: [FLINK-33418][test] Uses getHost()
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 <ma...@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()) {