You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2022/11/02 07:09:53 UTC
[flink] 03/05: [hotfix] Remove deprecated testcontainers API usages
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
commit 39f616e23ad4e3bf08be9cfe1aad5b5958d803e7
Author: Chesnay Schepler <ch...@apache.org>
AuthorDate: Tue Nov 1 15:26:40 2022 +0100
[hotfix] Remove deprecated testcontainers API usages
---
.../apache/flink/connectors/kinesis/testutils/KinesaliteContainer.java | 2 +-
.../flink/tests/util/kafka/containers/SchemaRegistryContainer.java | 2 +-
.../src/test/java/org/apache/flink/fs/s3/common/MinioTestContainer.java | 2 +-
3 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/flink-connectors/flink-connector-aws-kinesis-streams/src/test/java/org/apache/flink/connectors/kinesis/testutils/KinesaliteContainer.java b/flink-connectors/flink-connector-aws-kinesis-streams/src/test/java/org/apache/flink/connectors/kinesis/testutils/KinesaliteContainer.java
index 42593e559f4..b4044a52942 100644
--- a/flink-connectors/flink-connector-aws-kinesis-streams/src/test/java/org/apache/flink/connectors/kinesis/testutils/KinesaliteContainer.java
+++ b/flink-connectors/flink-connector-aws-kinesis-streams/src/test/java/org/apache/flink/connectors/kinesis/testutils/KinesaliteContainer.java
@@ -62,7 +62,7 @@ public class KinesaliteContainer extends GenericContainer<KinesaliteContainer> {
/** Returns the endpoint url to access the container from outside the docker network. */
public String getContainerEndpointUrl() {
- return String.format(URL_FORMAT, getContainerIpAddress(), getMappedPort(PORT));
+ return String.format(URL_FORMAT, getHost(), getMappedPort(PORT));
}
/** Returns the endpoint url to access the host from inside the docker network. */
diff --git a/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/containers/SchemaRegistryContainer.java b/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/containers/SchemaRegistryContainer.java
index 6bb6ac588f1..e71d7ac6687 100644
--- a/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/containers/SchemaRegistryContainer.java
+++ b/flink-end-to-end-tests/flink-end-to-end-tests-common-kafka/src/test/java/org/apache/flink/tests/util/kafka/containers/SchemaRegistryContainer.java
@@ -46,6 +46,6 @@ public class SchemaRegistryContainer extends GenericContainer<SchemaRegistryCont
}
public String getSchemaRegistryUrl() {
- return "http://" + getContainerIpAddress() + ":" + getMappedPort(8082);
+ return "http://" + getHost() + ":" + getMappedPort(8082);
}
}
diff --git a/flink-filesystems/flink-s3-fs-base/src/test/java/org/apache/flink/fs/s3/common/MinioTestContainer.java b/flink-filesystems/flink-s3-fs-base/src/test/java/org/apache/flink/fs/s3/common/MinioTestContainer.java
index c691ab9d716..f55075a7bfd 100644
--- a/flink-filesystems/flink-s3-fs-base/src/test/java/org/apache/flink/fs/s3/common/MinioTestContainer.java
+++ b/flink-filesystems/flink-s3-fs-base/src/test/java/org/apache/flink/fs/s3/common/MinioTestContainer.java
@@ -101,7 +101,7 @@ public class MinioTestContainer extends GenericContainer<MinioTestContainer> {
}
private String getHttpEndpoint() {
- return String.format("http://%s:%s", getContainerIpAddress(), getMappedPort(DEFAULT_PORT));
+ return String.format("http://%s:%s", getHost(), getMappedPort(DEFAULT_PORT));
}
/**