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/07/03 14:00:26 UTC
[flink] branch release-1.17 updated: [FLINK-30141][s3][filesystem] Increase retries on MinIO container startup
This is an automated email from the ASF dual-hosted git repository.
mapohl pushed a commit to branch release-1.17
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.17 by this push:
new 9344732e374 [FLINK-30141][s3][filesystem] Increase retries on MinIO container startup
9344732e374 is described below
commit 9344732e37469225ffc935e424fac0aac8434981
Author: Ryan Skraba <rs...@apache.org>
AuthorDate: Wed Jun 21 17:04:17 2023 +0200
[FLINK-30141][s3][filesystem] Increase retries on MinIO container startup
---
.../test/java/org/apache/flink/fs/s3/common/MinioTestContainer.java | 3 +++
1 file changed, 3 insertions(+)
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 f55075a7bfd..354be949aed 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
@@ -75,6 +75,9 @@ public class MinioTestContainer extends GenericContainer<MinioTestContainer> {
.forPort(DEFAULT_PORT)
.forPath(HEALTH_ENDPOINT)
.withStartupTimeout(Duration.ofMinutes(2)));
+ // Very rarely, a 503 status will be returned continuously while the container is
+ // starting up, slipping past the AmazonS3 client's default retry strategy.
+ withStartupAttempts(3);
}
@Override