[hotfix] Remove deprecated testcontainers API usages

DarkAssassinator · Nov 2, 2022 · 39f616e · 39f616e
1 parent 59137cb
commit 39f616e
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/...eams/src/test/java/org/apache/flink/connectors/kinesis/testutils/KinesaliteContainer.java b/...eams/src/test/java/org/apache/flink/connectors/kinesis/testutils/KinesaliteContainer.java
@@ -62,7 +62,7 @@ public KinesaliteContainer(DockerImageName imageName) {
 
     /** 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/...a/src/test/java/org/apache/flink/tests/util/kafka/containers/SchemaRegistryContainer.java b/...a/src/test/java/org/apache/flink/tests/util/kafka/containers/SchemaRegistryContainer.java
@@ -46,6 +46,6 @@ protected void configure() {
     }
 
     public String getSchemaRegistryUrl() {
-        return "http://" + getContainerIpAddress() + ":" + getMappedPort(8082);
+        return "http://" + getHost() + ":" + getMappedPort(8082);
     }
 }
diff --git a/...tems/flink-s3-fs-base/src/test/java/org/apache/flink/fs/s3/common/MinioTestContainer.java b/...tems/flink-s3-fs-base/src/test/java/org/apache/flink/fs/s3/common/MinioTestContainer.java
@@ -101,7 +101,7 @@ public AmazonS3 getClient() {
     }
 
     private String getHttpEndpoint() {
-        return String.format("http://%s:%s", getContainerIpAddress(), getMappedPort(DEFAULT_PORT));
+        return String.format("http://%s:%s", getHost(), getMappedPort(DEFAULT_PORT));
     }
 
     /**
-Original file line number
+Diff line change
@@ Expand Up / @@ -101,7 +101,7 @@ public AmazonS3 getClient() { @@
         }
         private String getHttpEndpoint() {
-            return String.format("http://%s:%s", getContainerIpAddress(), getMappedPort(DEFAULT_PORT));
+            return String.format("http://%s:%s", getHost(), getMappedPort(DEFAULT_PORT));
         }
         /**
@@ Expand Down @@