This is an automated email from the ASF dual-hosted git repository.
shenghang 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 a9e50ec10d [Hotfix] [connector-jdbc-e2e-part-7] CI failure caused by a
conflict during container deletion (#9922)
a9e50ec10d is described below
commit a9e50ec10d31d228be4c6d047006014848f4d91e
Author: Jast <[email protected]>
AuthorDate: Thu Oct 9 17:12:22 2025 +0800
[Hotfix] [connector-jdbc-e2e-part-7] CI failure caused by a conflict during
container deletion (#9922)
---
.../seatunnel/connectors/seatunnel/jdbc/MetalakeIT.java | 11 +----------
1 file changed, 1 insertion(+), 10 deletions(-)
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/MetalakeIT.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/MetalakeIT.java
index 407346beae..619ef5ab93 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/MetalakeIT.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/MetalakeIT.java
@@ -29,7 +29,6 @@ import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.Assertions;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
-import org.testcontainers.DockerClientFactory;
import org.testcontainers.containers.Container;
import org.testcontainers.containers.GenericContainer;
import org.testcontainers.containers.MySQLContainer;
@@ -41,8 +40,6 @@ import org.testcontainers.utility.DockerImageName;
import org.testcontainers.utility.DockerLoggerFactory;
import org.testcontainers.utility.MountableFile;
-import com.github.dockerjava.api.DockerClient;
-
import java.io.IOException;
import java.math.BigDecimal;
import java.nio.file.Paths;
@@ -74,8 +71,6 @@ public class MetalakeIT extends SeaTunnelContainer {
protected Catalog catalog;
- protected DockerClient dockerClient = DockerClientFactory.lazyClient();
-
protected static final String HOST = "HOST";
private static final String MYSQL_IMAGE = "mysql:8.0";
@@ -89,9 +84,6 @@ public class MetalakeIT extends SeaTunnelContainer {
private static final String MYSQL_PASSWORD = "Abc!@#135_seatunnel";
private static final int MYSQL_PORT = 3306;
private static final String MYSQL_URL = "jdbc:mysql://" + HOST +
":%s/%s?useSSL=false";
- private static final String URL = "jdbc:mysql://" + HOST +
":3306/seatunnel";
-
- private static final String SQL = "select * from seatunnel.source";
private static final String DRIVER_CLASS = "com.mysql.cj.jdbc.Driver";
@@ -112,7 +104,6 @@ public class MetalakeIT extends SeaTunnelContainer {
@BeforeEach
@Override
public void startUp() throws Exception {
- // super.startUp();
server =
new GenericContainer<>(getDockerImage())
.withNetwork(NETWORK)
@@ -196,7 +187,7 @@ public class MetalakeIT extends SeaTunnelContainer {
}
@Test
- public void TestMetalake() throws IOException, InterruptedException {
+ public void testMetalake() throws IOException, InterruptedException {
Container.ExecResult execResult =
executeJob("/jdbc_mysql_source_to_assert_sink_with_metalake.conf");
Assertions.assertEquals(0, execResult.getExitCode());