Skip to content

Commit a4a7377

Browse files
author
yu
committed
[FLINK-26907] RMQSourceITCase failed on azure due to container startup failed
1 parent fb0566a commit a4a7377

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

flink-connector-rabbitmq/src/test/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSourceITCase.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -88,7 +88,8 @@ public class RMQSourceITCase {
8888
public static final RabbitMQContainer RMQ_CONTAINER =
8989
new RabbitMQContainer(DockerImageName.parse(DockerImageVersions.RABBITMQ))
9090
.withExposedPorts(RABBITMQ_PORT)
91-
.withLogConsumer(LOG_CONSUMER);
91+
.withLogConsumer(LOG_CONSUMER)
92+
.withStartupAttempts(3);
9293

9394
@Before
9495
public void setUp() throws Exception {

0 commit comments

Comments
 (0)