This is an automated email from the ASF dual-hosted git repository.
martijnvisser pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/flink-connector-rabbitmq.git
The following commit(s) were added to refs/heads/main by this push:
new 7203c95 [FLINK-26907] RMQSourceITCase failed on Azure due to
container startup failed. This closes #20
7203c95 is described below
commit 7203c951987412c669e9b7ca75d5a8584b2b8c80
Author: yuxiang <[email protected]>
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>
---
.../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 {
