fix

apache · Jun 16, 2023 · 194ade0 · 194ade0
1 parent d723b5f
commit 194ade0
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/...tunnel-connector-v2-e2e/connector-cdc-mongodb-e2e/src/test/java/mongodb/MongodbCDCIT.java b/...tunnel-connector-v2-e2e/connector-cdc-mongodb-e2e/src/test/java/mongodb/MongodbCDCIT.java
@@ -158,7 +158,7 @@ public void testMongodbCdcToMysqlCheckDataE2e(TestContainer container) {
         // insert update delete
         upsertDeleteSourceTable();
 
-        await().atMost(60000, TimeUnit.MILLISECONDS)
+        await().atMost(240000, TimeUnit.MILLISECONDS)
                 .untilAsserted(
                         () -> {
                             Assertions.assertIterableEquals(

diff --git a/...sql-e2e/src/test/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/MysqlCDCIT.java b/...sql-e2e/src/test/java/org/apache/seatunnel/connectors/seatunnel/cdc/mysql/MysqlCDCIT.java
@@ -42,6 +42,7 @@
 import java.sql.ResultSet;
 import java.sql.SQLException;
 import java.util.ArrayList;
+import java.util.Collections;
 import java.util.List;
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.TimeUnit;
@@ -98,7 +99,8 @@ private static MySqlContainer createMySqlContainer(MySqlVersion version) {
                         .withLogConsumer(
                                 new Slf4jLogConsumer(
                                         DockerLoggerFactory.getLogger("mysql-docker-image")));
-
+        // For local test use
+        mySqlContainer.setPortBindings(Collections.singletonList("3308:3306"));
         return mySqlContainer;
     }