diff --git a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-pulsar-e2e/src/test/java/org/apache/seatunnel/e2e/connector/pulsar/CanalToPulsarIT.java b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-pulsar-e2e/src/test/java/org/apache/seatunnel/e2e/connector/pulsar/CanalToPulsarIT.java index c46677adb50..c4d8530b16a 100644 --- a/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-pulsar-e2e/src/test/java/org/apache/seatunnel/e2e/connector/pulsar/CanalToPulsarIT.java +++ b/seatunnel-e2e/seatunnel-connector-v2-e2e/connector-pulsar-e2e/src/test/java/org/apache/seatunnel/e2e/connector/pulsar/CanalToPulsarIT.java @@ -23,7 +23,6 @@ import org.apache.seatunnel.connectors.seatunnel.cdc.mysql.testutils.UniqueDatabase; import org.apache.seatunnel.e2e.common.TestResource; import org.apache.seatunnel.e2e.common.TestSuiteBase; -import org.apache.seatunnel.e2e.common.container.ContainerExtendedFactory; import org.apache.seatunnel.e2e.common.container.CopyFileBeforeStart; import org.apache.seatunnel.e2e.common.container.EngineType; import org.apache.seatunnel.e2e.common.container.TestContainer; @@ -120,16 +119,6 @@ private static MySqlContainer createMySqlContainer(MySqlVersion version) { private static PostgreSQLContainer POSTGRESQL_CONTAINER; - @TestContainerExtension - private final ContainerExtendedFactory extendedFactory = - container -> { - Container.ExecResult extraCommands = - container.execInContainer( - "bash", "-c", "cd /tmp/seatunnel/lib && curl -O " + PG_DRIVER_JAR); - - Assertions.assertEquals(0, extraCommands.getExitCode()); - }; - @TestContainerExtension private final CopyFileBeforeStart copyFileBeforeStart = () -> { diff --git a/seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/container/flink/AbstractTestFlinkContainer.java b/seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/container/flink/AbstractTestFlinkContainer.java index 9d75308ea01..374a779f145 100644 --- a/seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/container/flink/AbstractTestFlinkContainer.java +++ b/seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/container/flink/AbstractTestFlinkContainer.java @@ -108,7 +108,7 @@ public void startUp() throws Exception { if (filePaths != null) { filePaths.forEach( filePath -> { - jobManager.copyFileToContainer( + jobManager.withCopyFileToContainer( MountableFile.forHostPath(filePath), SEATUNNEL_HOME + "/plugins/jdbc/lib"); }); diff --git a/seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/container/spark/AbstractTestSparkContainer.java b/seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/container/spark/AbstractTestSparkContainer.java index 707ede1fa16..f5f82f023a7 100644 --- a/seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/container/spark/AbstractTestSparkContainer.java +++ b/seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/container/spark/AbstractTestSparkContainer.java @@ -71,7 +71,7 @@ public void startUp() throws Exception { if (copyFilePaths != null) { copyFilePaths.forEach( copyFilePath -> { - master.copyFileToContainer( + master.withCopyFileToContainer( MountableFile.forHostPath(copyFilePath), SEATUNNEL_HOME + "/plugins/jdbc/lib"); });