This is an automated email from the ASF dual-hosted git repository.
zhangshenghang pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
The following commit(s) were added to refs/heads/dev by this push:
new 4e37f8b9ae [Fix][E2E][Jdbc] Fix IRIS e2e container startup failure by
upgrading image and adding wait strategy (#11019)
4e37f8b9ae is described below
commit 4e37f8b9ae2b64189b34ac7ddf36a75b75bd56e9
Author: zhangdonghao <[email protected]>
AuthorDate: Mon Jun 8 10:38:58 2026 +0800
[Fix][E2E][Jdbc] Fix IRIS e2e container startup failure by upgrading image
and adding wait strategy (#11019)
---
.../org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcDb2IT.java | 4 ++++
.../apache/seatunnel/connectors/seatunnel/jdbc/JdbcPhoenixIT.java | 4 ++++
.../seatunnel/connectors/seatunnel/jdbc/JdbcSelectDBCloudIT.java | 4 ++++
.../seatunnel/connectors/seatunnel/jdbc/JdbcStarRocksdbIT.java | 4 ++++
.../org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcHiveIT.java | 4 ++++
.../apache/seatunnel/connectors/seatunnel/jdbc/JdbcKingbaseIT.java | 4 ++++
.../apache/seatunnel/connectors/seatunnel/jdbc/JdbcVerticaIT.java | 4 ++++
.../seatunnel/connectors/seatunnel/jdbc/JdbcCloudberryIT.java | 4 ++++
.../org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcDmIT.java | 4 ++++
.../org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcDorisIT.java | 4 ++++
.../apache/seatunnel/connectors/seatunnel/jdbc/JdbcDorisdbIT.java | 4 ++++
.../apache/seatunnel/connectors/seatunnel/jdbc/JdbcGBase8aIT.java | 4 ++++
.../apache/seatunnel/connectors/seatunnel/jdbc/JdbcGreenplumIT.java | 4 ++++
.../apache/seatunnel/connectors/seatunnel/jdbc/JdbcHighGoIT.java | 4 ++++
.../org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcIrisIT.java | 6 +++++-
.../apache/seatunnel/connectors/seatunnel/jdbc/JdbcOpenGaussIT.java | 4 ++++
.../apache/seatunnel/connectors/seatunnel/jdbc/JdbcPrestoIT.java | 4 ++++
.../org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcTrinoIT.java | 4 ++++
.../org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcXuguIT.java | 4 ++++
19 files changed, 77 insertions(+), 1 deletion(-)
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-1/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcDb2IT.java
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-1/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcDb2IT.java
index 5d31659398..ee0633ee49 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-1/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcDb2IT.java
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-1/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcDb2IT.java
@@ -27,12 +27,14 @@ import
org.apache.seatunnel.common.exception.SeaTunnelRuntimeException;
import org.testcontainers.containers.Db2Container;
import org.testcontainers.containers.GenericContainer;
import org.testcontainers.containers.output.Slf4jLogConsumer;
+import org.testcontainers.containers.wait.strategy.Wait;
import org.testcontainers.utility.DockerLoggerFactory;
import java.math.BigDecimal;
import java.sql.Date;
import java.sql.SQLException;
import java.sql.Statement;
+import java.time.Duration;
import java.time.LocalDate;
import java.util.ArrayList;
import java.util.HashMap;
@@ -187,6 +189,8 @@ public class JdbcDb2IT extends AbstractJdbcIT {
.withDatabaseName(DB2_DATABASE)
.withUsername(DB2_USER)
.withPassword(DB2_PASSWORD)
+ .waitingFor(
+
Wait.forListeningPort().withStartupTimeout(Duration.ofMinutes(5)))
.withLogConsumer(
new
Slf4jLogConsumer(DockerLoggerFactory.getLogger(DB2_IMAGE)))
.acceptLicense();
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-2/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcPhoenixIT.java
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-2/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcPhoenixIT.java
index 0de7dbc991..d0e657ada9 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-2/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcPhoenixIT.java
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-2/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcPhoenixIT.java
@@ -25,11 +25,13 @@ import
org.apache.seatunnel.common.exception.SeaTunnelRuntimeException;
import org.testcontainers.containers.GenericContainer;
import org.testcontainers.containers.output.Slf4jLogConsumer;
+import org.testcontainers.containers.wait.strategy.Wait;
import org.testcontainers.utility.DockerImageName;
import org.testcontainers.utility.DockerLoggerFactory;
import java.sql.SQLException;
import java.sql.Statement;
+import java.time.Duration;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.HashMap;
@@ -153,6 +155,8 @@ public class JdbcPhoenixIT extends AbstractJdbcIT {
new GenericContainer<>(imageName)
.withNetwork(NETWORK)
.withNetworkAliases(PHOENIX_CONTAINER_HOST)
+ .waitingFor(
+
Wait.forListeningPort().withStartupTimeout(Duration.ofMinutes(5)))
.withLogConsumer(
new
Slf4jLogConsumer(DockerLoggerFactory.getLogger(PHOENIX_IMAGE)));
container.setPortBindings(
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-2/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcSelectDBCloudIT.java
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-2/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcSelectDBCloudIT.java
index c42be5c326..2b1ea538ed 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-2/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcSelectDBCloudIT.java
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-2/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcSelectDBCloudIT.java
@@ -35,6 +35,7 @@ import org.junit.jupiter.api.TestTemplate;
import org.testcontainers.containers.Container;
import org.testcontainers.containers.GenericContainer;
import org.testcontainers.containers.output.Slf4jLogConsumer;
+import org.testcontainers.containers.wait.strategy.Wait;
import org.testcontainers.lifecycle.Startables;
import org.testcontainers.shaded.org.apache.commons.io.IOUtils;
import org.testcontainers.utility.DockerLoggerFactory;
@@ -54,6 +55,7 @@ import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
+import java.time.Duration;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
@@ -187,6 +189,8 @@ public class JdbcSelectDBCloudIT extends TestSuiteBase
implements TestResource {
new GenericContainer<>(DOCKER_IMAGE)
.withNetwork(TestSuiteBase.NETWORK)
.withNetworkAliases(HOST)
+ .waitingFor(
+
Wait.forListeningPort().withStartupTimeout(Duration.ofMinutes(5)))
.withLogConsumer(
new
Slf4jLogConsumer(DockerLoggerFactory.getLogger(DOCKER_IMAGE)));
selectdbServer.setPortBindings(
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-2/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcStarRocksdbIT.java
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-2/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcStarRocksdbIT.java
index 480d18a410..86df617bee 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-2/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcStarRocksdbIT.java
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-2/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcStarRocksdbIT.java
@@ -29,11 +29,13 @@ import org.junit.jupiter.api.Assertions;
import org.testcontainers.containers.Container;
import org.testcontainers.containers.GenericContainer;
import org.testcontainers.containers.output.Slf4jLogConsumer;
+import org.testcontainers.containers.wait.strategy.Wait;
import org.testcontainers.utility.DockerLoggerFactory;
import java.math.BigDecimal;
import java.sql.Date;
import java.sql.Timestamp;
+import java.time.Duration;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.util.ArrayList;
@@ -177,6 +179,8 @@ public class JdbcStarRocksdbIT extends AbstractJdbcIT {
new GenericContainer<>(DOCKER_IMAGE)
.withNetwork(NETWORK)
.withNetworkAliases(NETWORK_ALIASES)
+ .waitingFor(
+
Wait.forListeningPort().withStartupTimeout(Duration.ofMinutes(5)))
.withLogConsumer(
new
Slf4jLogConsumer(DockerLoggerFactory.getLogger(DOCKER_IMAGE)));
container.setPortBindings(Lists.newArrayList(String.format("%s:%s",
9030, 9030)));
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-3/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcHiveIT.java
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-3/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcHiveIT.java
index 4cb9390d21..f4d37904be 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-3/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcHiveIT.java
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-3/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcHiveIT.java
@@ -33,11 +33,13 @@ import
org.apache.seatunnel.connectors.seatunnel.jdbc.utils.JdbcCatalogUtils;
import org.junit.jupiter.api.Assertions;
import org.testcontainers.containers.GenericContainer;
import org.testcontainers.containers.output.Slf4jLogConsumer;
+import org.testcontainers.containers.wait.strategy.Wait;
import org.testcontainers.utility.DockerLoggerFactory;
import lombok.extern.slf4j.Slf4j;
import java.sql.Statement;
+import java.time.Duration;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
@@ -202,6 +204,8 @@ public class JdbcHiveIT extends AbstractJdbcIT {
.withNetwork(NETWORK)
.withNetworkAliases(HIVE_CONTAINER_HOST)
.withEnv("SERVICE_NAME", "hiveserver2")
+ .waitingFor(
+
Wait.forListeningPort().withStartupTimeout(Duration.ofMinutes(5)))
.withLogConsumer(
new
Slf4jLogConsumer(DockerLoggerFactory.getLogger(HIVE_IMAGE)));
container.setPortBindings(Lists.newArrayList(String.format("%s:%s",
HIVE_PORT, HIVE_PORT)));
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-3/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcKingbaseIT.java
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-3/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcKingbaseIT.java
index f428b7fb1b..cc74581c65 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-3/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcKingbaseIT.java
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-3/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcKingbaseIT.java
@@ -26,10 +26,12 @@ import org.apache.seatunnel.common.utils.ExceptionUtils;
import org.junit.jupiter.api.Disabled;
import org.testcontainers.containers.GenericContainer;
import org.testcontainers.containers.output.Slf4jLogConsumer;
+import org.testcontainers.containers.wait.strategy.Wait;
import org.testcontainers.utility.DockerLoggerFactory;
import java.math.BigDecimal;
import java.sql.Statement;
+import java.time.Duration;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.LocalTime;
@@ -167,6 +169,8 @@ public class JdbcKingbaseIT extends AbstractJdbcIT {
.withNetworkAliases(KINGBASE_CONTAINER_HOST)
.withEnv("KINGBASE_SYSTEM_PASSWORD", "123456")
.withFileSystemBind(KM_LICENSE_PATH,
"/home/kingbase/license.dat")
+ .waitingFor(
+
Wait.forListeningPort().withStartupTimeout(Duration.ofMinutes(5)))
.withLogConsumer(
new Slf4jLogConsumer(
DockerLoggerFactory.getLogger(KINGBASE_IMAGE)));
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-3/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcVerticaIT.java
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-3/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcVerticaIT.java
index 4e40c275d8..c1be008c3e 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-3/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcVerticaIT.java
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-3/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcVerticaIT.java
@@ -26,8 +26,10 @@ import org.apache.seatunnel.api.table.type.SeaTunnelRow;
import org.junit.jupiter.api.Disabled;
import org.testcontainers.containers.GenericContainer;
import org.testcontainers.containers.output.Slf4jLogConsumer;
+import org.testcontainers.containers.wait.strategy.Wait;
import org.testcontainers.utility.DockerLoggerFactory;
+import java.time.Duration;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
@@ -122,6 +124,8 @@ public class JdbcVerticaIT extends AbstractJdbcIT {
new GenericContainer<>(VERTICA_IMAGE)
.withNetwork(NETWORK)
.withNetworkAliases(VERTICA_CONTAINER_HOST)
+ .waitingFor(
+
Wait.forListeningPort().withStartupTimeout(Duration.ofMinutes(5)))
.withLogConsumer(
new
Slf4jLogConsumer(DockerLoggerFactory.getLogger(VERTICA_IMAGE)));
container.setPortBindings(
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-5/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcCloudberryIT.java
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-5/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcCloudberryIT.java
index 7740405c43..5808ff0dcf 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-5/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcCloudberryIT.java
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-5/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcCloudberryIT.java
@@ -27,12 +27,14 @@ import org.testcontainers.containers.BindMode;
import org.testcontainers.containers.Container;
import org.testcontainers.containers.GenericContainer;
import org.testcontainers.containers.output.Slf4jLogConsumer;
+import org.testcontainers.containers.wait.strategy.Wait;
import org.testcontainers.images.PullPolicy;
import org.testcontainers.lifecycle.Startables;
import org.testcontainers.utility.DockerImageName;
import org.testcontainers.utility.DockerLoggerFactory;
import java.io.IOException;
+import java.time.Duration;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
@@ -131,6 +133,8 @@ public class JdbcCloudberryIT extends AbstractJdbcIT {
new GenericContainer<>(imageName)
.withNetwork(NETWORK)
.withNetworkAliases(CLOUDBERRY_CONTAINER_HOST)
+ .waitingFor(
+
Wait.forListeningPort().withStartupTimeout(Duration.ofMinutes(5)))
.withLogConsumer(
new Slf4jLogConsumer(
DockerLoggerFactory.getLogger(CLOUDBERRY_IMAGE)))
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-5/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcDmIT.java
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-5/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcDmIT.java
index 4bedf4b3d3..89298083a3 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-5/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcDmIT.java
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-5/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcDmIT.java
@@ -25,11 +25,13 @@ import org.apache.seatunnel.api.table.type.SeaTunnelRow;
import org.testcontainers.containers.GenericContainer;
import org.testcontainers.containers.output.Slf4jLogConsumer;
+import org.testcontainers.containers.wait.strategy.Wait;
import org.testcontainers.utility.DockerLoggerFactory;
import java.math.BigDecimal;
import java.sql.Date;
import java.sql.Timestamp;
+import java.time.Duration;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.util.ArrayList;
@@ -233,6 +235,8 @@ public class JdbcDmIT extends AbstractJdbcIT {
new GenericContainer<>(DM_IMAGE)
.withNetwork(NETWORK)
.withNetworkAliases(DM_CONTAINER_HOST)
+ .waitingFor(
+
Wait.forListeningPort().withStartupTimeout(Duration.ofMinutes(5)))
.withLogConsumer(
new
Slf4jLogConsumer(DockerLoggerFactory.getLogger(DM_IMAGE)));
container.setPortBindings(Lists.newArrayList(String.format("%s:%s",
5336, 5236)));
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-5/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcDorisIT.java
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-5/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcDorisIT.java
index 1bd168a325..fbf0be4938 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-5/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcDorisIT.java
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-5/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcDorisIT.java
@@ -35,6 +35,7 @@ import org.junit.jupiter.api.TestTemplate;
import org.testcontainers.containers.Container;
import org.testcontainers.containers.GenericContainer;
import org.testcontainers.containers.output.Slf4jLogConsumer;
+import org.testcontainers.containers.wait.strategy.Wait;
import org.testcontainers.lifecycle.Startables;
import org.testcontainers.shaded.org.apache.commons.io.IOUtils;
import org.testcontainers.utility.DockerLoggerFactory;
@@ -54,6 +55,7 @@ import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
+import java.time.Duration;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
@@ -188,6 +190,8 @@ public class JdbcDorisIT extends TestSuiteBase implements
TestResource {
.withNetwork(TestSuiteBase.NETWORK)
.withNetworkAliases(HOST)
.withPrivilegedMode(true)
+ .waitingFor(
+
Wait.forListeningPort().withStartupTimeout(Duration.ofMinutes(5)))
.withLogConsumer(
new
Slf4jLogConsumer(DockerLoggerFactory.getLogger(DOCKER_IMAGE)));
dorisServer.setPortBindings(Lists.newArrayList(String.format("%s:%s",
PORT, DOCKER_PORT)));
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-5/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcDorisdbIT.java
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-5/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcDorisdbIT.java
index af70d95337..fb8f3bc18e 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-5/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcDorisdbIT.java
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-5/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcDorisdbIT.java
@@ -35,6 +35,7 @@ import org.junit.jupiter.api.TestTemplate;
import org.testcontainers.containers.Container;
import org.testcontainers.containers.GenericContainer;
import org.testcontainers.containers.output.Slf4jLogConsumer;
+import org.testcontainers.containers.wait.strategy.Wait;
import org.testcontainers.lifecycle.Startables;
import org.testcontainers.shaded.org.apache.commons.io.IOUtils;
@@ -53,6 +54,7 @@ import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
+import java.time.Duration;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
@@ -185,6 +187,8 @@ public class JdbcDorisdbIT extends TestSuiteBase implements
TestResource {
new GenericContainer<>(DOCKER_IMAGE)
.withNetwork(TestSuiteBase.NETWORK)
.withNetworkAliases(HOST)
+ .waitingFor(
+
Wait.forListeningPort().withStartupTimeout(Duration.ofMinutes(5)))
.withLogConsumer(new Slf4jLogConsumer(log));
dorisServer.setPortBindings(Lists.newArrayList(String.format("%s:%s",
PORT, DOCKER_PORT)));
Startables.deepStart(Stream.of(dorisServer)).join();
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-5/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcGBase8aIT.java
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-5/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcGBase8aIT.java
index ef272f13fa..3403bac6ee 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-5/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcGBase8aIT.java
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-5/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcGBase8aIT.java
@@ -26,11 +26,13 @@ import
org.apache.seatunnel.common.exception.SeaTunnelRuntimeException;
import org.testcontainers.containers.GenericContainer;
import org.testcontainers.containers.output.Slf4jLogConsumer;
+import org.testcontainers.containers.wait.strategy.Wait;
import org.testcontainers.utility.DockerLoggerFactory;
import java.math.BigDecimal;
import java.sql.Date;
import java.sql.Timestamp;
+import java.time.Duration;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.util.ArrayList;
@@ -170,6 +172,8 @@ public class JdbcGBase8aIT extends AbstractJdbcIT {
new GenericContainer<>(GBASE_IMAGE)
.withNetwork(NETWORK)
.withNetworkAliases(GBASE_CONTAINER_HOST)
+ .waitingFor(
+
Wait.forListeningPort().withStartupTimeout(Duration.ofMinutes(5)))
.withLogConsumer(
new
Slf4jLogConsumer(DockerLoggerFactory.getLogger(GBASE_IMAGE)));
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-5/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcGreenplumIT.java
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-5/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcGreenplumIT.java
index 4de04c05e6..437ee9093f 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-5/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcGreenplumIT.java
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-5/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcGreenplumIT.java
@@ -24,9 +24,11 @@ import org.apache.seatunnel.api.table.type.SeaTunnelRow;
import org.testcontainers.containers.GenericContainer;
import org.testcontainers.containers.output.Slf4jLogConsumer;
+import org.testcontainers.containers.wait.strategy.Wait;
import org.testcontainers.utility.DockerImageName;
import org.testcontainers.utility.DockerLoggerFactory;
+import java.time.Duration;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
@@ -121,6 +123,8 @@ public class JdbcGreenplumIT extends AbstractJdbcIT {
new GenericContainer<>(imageName)
.withNetwork(NETWORK)
.withNetworkAliases(GREENPLUM_CONTAINER_HOST)
+ .waitingFor(
+
Wait.forListeningPort().withStartupTimeout(Duration.ofMinutes(5)))
.withLogConsumer(
new Slf4jLogConsumer(
DockerLoggerFactory.getLogger(GREENPLUM_IMAGE)));
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-7/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcHighGoIT.java
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-7/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcHighGoIT.java
index 7dafdfba4c..28e48821f3 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-7/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcHighGoIT.java
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-7/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcHighGoIT.java
@@ -38,9 +38,11 @@ import org.junit.jupiter.api.Test;
import org.testcontainers.containers.Container;
import org.testcontainers.containers.GenericContainer;
import org.testcontainers.containers.output.Slf4jLogConsumer;
+import org.testcontainers.containers.wait.strategy.Wait;
import org.testcontainers.utility.DockerLoggerFactory;
import java.math.BigDecimal;
+import java.time.Duration;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.util.ArrayList;
@@ -285,6 +287,8 @@ public class JdbcHighGoIT extends AbstractJdbcIT {
new GenericContainer<>(HIGHGO_IMAGE)
.withNetwork(NETWORK)
.withNetworkAliases(HIGHGO_ALIASES)
+ .waitingFor(
+
Wait.forListeningPort().withStartupTimeout(Duration.ofMinutes(5)))
.withLogConsumer(
new
Slf4jLogConsumer(DockerLoggerFactory.getLogger(HIGHGO_IMAGE)));
container.setPortBindings(
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-7/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcIrisIT.java
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-7/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcIrisIT.java
index fe9a480745..feefd5469c 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-7/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcIrisIT.java
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-7/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcIrisIT.java
@@ -42,6 +42,7 @@ import org.junit.jupiter.api.TestTemplate;
import org.testcontainers.containers.Container;
import org.testcontainers.containers.GenericContainer;
import org.testcontainers.containers.output.Slf4jLogConsumer;
+import org.testcontainers.containers.wait.strategy.Wait;
import org.testcontainers.utility.DockerLoggerFactory;
import org.testcontainers.utility.MountableFile;
@@ -56,6 +57,7 @@ import java.sql.SQLException;
import java.sql.Statement;
import java.sql.Time;
import java.sql.Timestamp;
+import java.time.Duration;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.LocalTime;
@@ -68,7 +70,7 @@ import java.util.stream.Collectors;
@Slf4j
public class JdbcIrisIT extends AbstractJdbcIT {
- private static final String IRIS_IMAGE =
"intersystems/iris-community:2025.1";
+ private static final String IRIS_IMAGE =
"intersystems/iris-community:2025.3";
private static final String IRIS_NETWORK_ALIASES = "e2e_irisDb";
private static final String DRIVER_CLASS =
"com.intersystems.jdbc.IRISDriver";
private static final int IRIS_PORT = 1972;
@@ -559,6 +561,8 @@ public class JdbcIrisIT extends AbstractJdbcIT {
.withNetwork(NETWORK)
.withNetworkAliases(IRIS_NETWORK_ALIASES)
.withExposedPorts(IRIS_PORT)
+ .waitingFor(
+
Wait.forListeningPort().withStartupTimeout(Duration.ofMinutes(5)))
.withLogConsumer(
new
Slf4jLogConsumer(DockerLoggerFactory.getLogger(IRIS_IMAGE)));
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-7/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcOpenGaussIT.java
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-7/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcOpenGaussIT.java
index 191b4d2701..f6eff62a9d 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-7/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcOpenGaussIT.java
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-7/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcOpenGaussIT.java
@@ -39,11 +39,13 @@ import org.junit.jupiter.api.Test;
import org.testcontainers.containers.Container;
import org.testcontainers.containers.GenericContainer;
import org.testcontainers.containers.output.Slf4jLogConsumer;
+import org.testcontainers.containers.wait.strategy.Wait;
import org.testcontainers.utility.DockerLoggerFactory;
import lombok.extern.slf4j.Slf4j;
import java.math.BigDecimal;
+import java.time.Duration;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.util.ArrayList;
@@ -306,6 +308,8 @@ public class JdbcOpenGaussIT extends AbstractJdbcIT {
.withNetwork(NETWORK)
.withNetworkAliases(OPEN_GAUSS_ALIASES)
.withEnv("GS_PASSWORD", PASSWORD)
+ .waitingFor(
+
Wait.forListeningPort().withStartupTimeout(Duration.ofMinutes(5)))
.withLogConsumer(
new Slf4jLogConsumer(
DockerLoggerFactory.getLogger(OPENGAUSS_IMAGE)));
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-7/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcPrestoIT.java
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-7/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcPrestoIT.java
index e525322d55..398c0c8512 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-7/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcPrestoIT.java
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-7/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcPrestoIT.java
@@ -30,6 +30,7 @@ import org.junit.jupiter.api.Assertions;
import org.testcontainers.containers.Container;
import org.testcontainers.containers.GenericContainer;
import org.testcontainers.containers.output.Slf4jLogConsumer;
+import org.testcontainers.containers.wait.strategy.Wait;
import org.testcontainers.utility.DockerLoggerFactory;
import lombok.extern.slf4j.Slf4j;
@@ -37,6 +38,7 @@ import lombok.extern.slf4j.Slf4j;
import java.sql.Driver;
import java.sql.SQLException;
import java.sql.Statement;
+import java.time.Duration;
import java.util.List;
import java.util.Properties;
import java.util.concurrent.TimeUnit;
@@ -220,6 +222,8 @@ public class JdbcPrestoIT extends AbstractJdbcIT {
new GenericContainer<>(PRESTO_IMAGE)
.withNetwork(NETWORK)
.withNetworkAliases(PRESTO_ALIASES)
+ .waitingFor(
+
Wait.forListeningPort().withStartupTimeout(Duration.ofMinutes(5)))
.withLogConsumer(
new
Slf4jLogConsumer(DockerLoggerFactory.getLogger(PRESTO_IMAGE)));
container.setPortBindings(Lists.newArrayList(String.format("%s:%s",
PRESTO_PORT, "8080")));
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-7/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcTrinoIT.java
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-7/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcTrinoIT.java
index f0accb7b44..6cd57e7a54 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-7/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcTrinoIT.java
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-7/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcTrinoIT.java
@@ -30,6 +30,7 @@ import org.junit.jupiter.api.Assertions;
import org.testcontainers.containers.Container;
import org.testcontainers.containers.GenericContainer;
import org.testcontainers.containers.output.Slf4jLogConsumer;
+import org.testcontainers.containers.wait.strategy.Wait;
import org.testcontainers.utility.DockerLoggerFactory;
import lombok.extern.slf4j.Slf4j;
@@ -37,6 +38,7 @@ import lombok.extern.slf4j.Slf4j;
import java.sql.Driver;
import java.sql.SQLException;
import java.sql.Statement;
+import java.time.Duration;
import java.util.List;
import java.util.Properties;
import java.util.concurrent.TimeUnit;
@@ -220,6 +222,8 @@ public class JdbcTrinoIT extends AbstractJdbcIT {
new GenericContainer<>(TRINO_IMAGE)
.withNetwork(NETWORK)
.withNetworkAliases(TRINO_ALIASES)
+ .waitingFor(
+
Wait.forListeningPort().withStartupTimeout(Duration.ofMinutes(5)))
.withLogConsumer(
new
Slf4jLogConsumer(DockerLoggerFactory.getLogger(TRINO_IMAGE)));
container.setPortBindings(Lists.newArrayList(String.format("%s:%s",
TRINO_PORT, "8080")));
diff --git
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-7/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcXuguIT.java
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-7/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcXuguIT.java
index 78a18b4acc..6b027ee3ed 100644
---
a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-7/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcXuguIT.java
+++
b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-jdbc-e2e/connector-jdbc-e2e-part-7/src/test/java/org/apache/seatunnel/connectors/seatunnel/jdbc/JdbcXuguIT.java
@@ -32,6 +32,7 @@ import org.junit.jupiter.api.Test;
import org.testcontainers.containers.Container;
import org.testcontainers.containers.GenericContainer;
import org.testcontainers.containers.output.Slf4jLogConsumer;
+import org.testcontainers.containers.wait.strategy.Wait;
import org.testcontainers.utility.DockerLoggerFactory;
import lombok.extern.slf4j.Slf4j;
@@ -40,6 +41,7 @@ import java.math.BigDecimal;
import java.sql.Date;
import java.sql.Time;
import java.sql.Timestamp;
+import java.time.Duration;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.LocalTime;
@@ -222,6 +224,8 @@ public class JdbcXuguIT extends AbstractJdbcIT {
new GenericContainer<>(XUGU_IMAGE)
.withNetwork(NETWORK)
.withNetworkAliases(XUGU_CONTAINER_HOST)
+ .waitingFor(
+
Wait.forListeningPort().withStartupTimeout(Duration.ofMinutes(5)))
.withLogConsumer(
new
Slf4jLogConsumer(DockerLoggerFactory.getLogger(XUGU_IMAGE)));
container.setPortBindings(Lists.newArrayList(String.format("%s:%s",
XUGU_PORT, XUGU_PORT)));
