This is an automated email from the ASF dual-hosted git repository.

wanghailin 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 349218dbdb [Hotfix][CI][JDBC] Fix unstable e2e jdbc part 1 (#6292)
349218dbdb is described below

commit 349218dbdb7a79ad4b506b3c211dd8871e942d67
Author: Chengyu Yan <[email protected]>
AuthorDate: Fri Jan 26 16:12:34 2024 +0800

    [Hotfix][CI][JDBC] Fix unstable e2e jdbc part 1 (#6292)
---
 .../seatunnel/connectors/seatunnel/jdbc/JdbcMysqlMultipleTablesIT.java  | 2 ++
 1 file changed, 2 insertions(+)

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/JdbcMysqlMultipleTablesIT.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/JdbcMysqlMultipleTablesIT.java
index 55722792e4..64c4abe748 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/JdbcMysqlMultipleTablesIT.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/JdbcMysqlMultipleTablesIT.java
@@ -38,6 +38,7 @@ import org.testcontainers.containers.Container;
 import org.testcontainers.containers.MySQLContainer;
 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.DockerLoggerFactory;
 
@@ -223,6 +224,7 @@ public class JdbcMysqlMultipleTablesIT extends 
TestSuiteBase implements TestReso
                         .withNetworkAliases(MYSQL_CONTAINER_HOST)
                         .withExposedPorts(MYSQL_PORT)
                         .waitingFor(Wait.forHealthcheck())
+                        .withImagePullPolicy(PullPolicy.alwaysPull())
                         .withLogConsumer(
                                 new 
Slf4jLogConsumer(DockerLoggerFactory.getLogger(MYSQL_IMAGE)));
 

Reply via email to