update test case

Hisoka-X · Jun 5, 2023 · 55ac1e5 · 55ac1e5
1 parent 4d5b417
commit 55ac1e5
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 13 deletions.
diff --git a/...r-pulsar-e2e/src/test/java/org/apache/seatunnel/e2e/connector/pulsar/CanalToPulsarIT.java b/...r-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/...test/java/org/apache/seatunnel/e2e/common/container/flink/AbstractTestFlinkContainer.java b/...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/...test/java/org/apache/seatunnel/e2e/common/container/spark/AbstractTestSparkContainer.java b/...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");
                     });