[mongodb] [tests] Loosen E2E timeout limitations

This closes #2334. (cherry picked from commit 883b684)
apache · Oct 31, 2023 · 30e9761 · 30e9761
1 parent 0ff6e26
commit 30e9761
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 2 deletions.
diff --git a/flink-cdc-e2e-tests/src/test/java/com/ververica/cdc/connectors/tests/MongoE2eITCase.java b/flink-cdc-e2e-tests/src/test/java/com/ververica/cdc/connectors/tests/MongoE2eITCase.java
@@ -100,7 +100,8 @@ public void before() {
                 new MongoDBContainer(NETWORK, MongoDBContainer.ShardingClusterRole.ROUTER)
                         .dependsOn(shard)
                         .withNetworkAliases(INTER_CONTAINER_MONGO_ALIAS)
-                        .withLogConsumer(new Slf4jLogConsumer(LOG));
+                        .withLogConsumer(new Slf4jLogConsumer(LOG))
+                        .withStartupTimeout(Duration.ofSeconds(120));
 
         Startables.deepStart(Stream.of(config)).join();
         Startables.deepStart(Stream.of(shard)).join();
@@ -237,7 +238,7 @@ public void testMongoDbCDC() throws Exception {
                 expectResult,
                 "mongodb_products_sink",
                 new String[] {"id", "name", "description", "weight"},
-                60000L);
+                150000L);
     }
 
     private Document productDocOf(String id, String name, String description, Double weight) {

diff --git a/...ongodb-cdc/src/test/java/com/ververica/cdc/connectors/mongodb/utils/MongoDBContainer.java b/...ongodb-cdc/src/test/java/com/ververica/cdc/connectors/mongodb/utils/MongoDBContainer.java
@@ -30,6 +30,7 @@
 import java.net.URL;
 import java.nio.file.Files;
 import java.nio.file.Paths;
+import java.time.Duration;
 import java.util.Random;
 import java.util.regex.Matcher;
 import java.util.regex.Pattern;
@@ -101,6 +102,11 @@ public String getHostAndPort() {
         return String.format("%s:%s", getContainerIpAddress(), getMappedPort(MONGODB_PORT));
     }
 
+    @Override
+    public MongoDBContainer withStartupTimeout(Duration timeout) {
+        return (MongoDBContainer) super.withStartupTimeout(timeout);
+    }
+
     public void executeCommand(String command) {
         try {
             LOG.info("Executing mongo command: {}", command);