This is an automated email from the ASF dual-hosted git repository.
martijnvisser pushed a commit to branch v3.0
in repository https://gitbox.apache.org/repos/asf/flink-connector-rabbitmq.git
The following commit(s) were added to refs/heads/v3.0 by this push:
new 8672727 [FLINK-26907] RMQSourceITCase failed on Azure due to
container startup failed. This closes #20
8672727 is described below
commit 8672727f3643f19c951afcf20369ccf06aea9b56
Author: yuxiang <384669...@qq.com>
AuthorDate: Mon Jan 8 17:00:24 2024 +0800
[FLINK-26907] RMQSourceITCase failed on Azure due to container startup
failed. This closes #20
Co-authored-by: yu <13485876233>
(cherry picked from commit 7203c951987412c669e9b7ca75d5a8584b2b8c80)
---
.../apache/flink/streaming/connectors/rabbitmq/RMQSourceITCase.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git
a/flink-connector-rabbitmq/src/test/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSourceITCase.java
b/flink-connector-rabbitmq/src/test/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSourceITCase.java
index a245d54..db3a32e 100644
---
a/flink-connector-rabbitmq/src/test/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSourceITCase.java
+++
b/flink-connector-rabbitmq/src/test/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSourceITCase.java
@@ -88,7 +88,8 @@ public class RMQSourceITCase {
public static final RabbitMQContainer RMQ_CONTAINER =
new
RabbitMQContainer(DockerImageName.parse(DockerImageVersions.RABBITMQ))
.withExposedPorts(RABBITMQ_PORT)
- .withLogConsumer(LOG_CONSUMER);
+ .withLogConsumer(LOG_CONSUMER)
+ .withStartupAttempts(3);
@Before
public void setUp() throws Exception {
