This is an automated email from the ASF dual-hosted git repository.
trohrmann pushed a commit to branch release-1.14
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.14 by this push:
new b8810cc [FLINK-24806][connectors/rabbitmq] Fix container startup in
RMQSourceITCase
b8810cc is described below
commit b8810cc68969c2dc8dd51158d222650e76a3b56b
Author: Michal Ciesielczyk <[email protected]>
AuthorDate: Mon Nov 8 02:52:58 2021 +0100
[FLINK-24806][connectors/rabbitmq] Fix container startup in RMQSourceITCase
This closes #17709.
---
.../apache/flink/streaming/connectors/rabbitmq/RMQSourceITCase.java | 4 +---
1 file changed, 1 insertion(+), 3 deletions(-)
diff --git
a/flink-connectors/flink-connector-rabbitmq/src/test/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSourceITCase.java
b/flink-connectors/flink-connector-rabbitmq/src/test/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSourceITCase.java
index 7f462f5..78d0fa7 100644
---
a/flink-connectors/flink-connector-rabbitmq/src/test/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSourceITCase.java
+++
b/flink-connectors/flink-connector-rabbitmq/src/test/java/org/apache/flink/streaming/connectors/rabbitmq/RMQSourceITCase.java
@@ -50,7 +50,6 @@ import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.testcontainers.containers.RabbitMQContainer;
import org.testcontainers.containers.output.Slf4jLogConsumer;
-import org.testcontainers.containers.wait.strategy.Wait;
import org.testcontainers.utility.DockerImageName;
import java.io.IOException;
@@ -90,8 +89,7 @@ public class RMQSourceITCase {
public static final RabbitMQContainer RMQ_CONTAINER =
new
RabbitMQContainer(DockerImageName.parse(DockerImageVersions.RABBITMQ))
.withExposedPorts(RABBITMQ_PORT)
- .withLogConsumer(LOG_CONSUMER)
- .waitingFor(Wait.forListeningPort());
+ .withLogConsumer(LOG_CONSUMER);
@Before
public void setUp() throws Exception {
