Skip to content

Commit 55ac1e5

Browse files
committed
update test case
1 parent 4d5b417 commit 55ac1e5

File tree

3 files changed

+2
-13
lines changed

3 files changed

+2
-13
lines changed

seatunnel-e2e/seatunnel-connector-v2-e2e/connector-pulsar-e2e/src/test/java/org/apache/seatunnel/e2e/connector/pulsar/CanalToPulsarIT.java

Lines changed: 0 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,6 @@
2323
import org.apache.seatunnel.connectors.seatunnel.cdc.mysql.testutils.UniqueDatabase;
2424
import org.apache.seatunnel.e2e.common.TestResource;
2525
import org.apache.seatunnel.e2e.common.TestSuiteBase;
26-
import org.apache.seatunnel.e2e.common.container.ContainerExtendedFactory;
2726
import org.apache.seatunnel.e2e.common.container.CopyFileBeforeStart;
2827
import org.apache.seatunnel.e2e.common.container.EngineType;
2928
import org.apache.seatunnel.e2e.common.container.TestContainer;
@@ -120,16 +119,6 @@ private static MySqlContainer createMySqlContainer(MySqlVersion version) {
120119

121120
private static PostgreSQLContainer<?> POSTGRESQL_CONTAINER;
122121

123-
@TestContainerExtension
124-
private final ContainerExtendedFactory extendedFactory =
125-
container -> {
126-
Container.ExecResult extraCommands =
127-
container.execInContainer(
128-
"bash", "-c", "cd /tmp/seatunnel/lib && curl -O " + PG_DRIVER_JAR);
129-
130-
Assertions.assertEquals(0, extraCommands.getExitCode());
131-
};
132-
133122
@TestContainerExtension
134123
private final CopyFileBeforeStart copyFileBeforeStart =
135124
() -> {

seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/container/flink/AbstractTestFlinkContainer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -108,7 +108,7 @@ public void startUp() throws Exception {
108108
if (filePaths != null) {
109109
filePaths.forEach(
110110
filePath -> {
111-
jobManager.copyFileToContainer(
111+
jobManager.withCopyFileToContainer(
112112
MountableFile.forHostPath(filePath),
113113
SEATUNNEL_HOME + "/plugins/jdbc/lib");
114114
});

seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/container/spark/AbstractTestSparkContainer.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -71,7 +71,7 @@ public void startUp() throws Exception {
7171
if (copyFilePaths != null) {
7272
copyFilePaths.forEach(
7373
copyFilePath -> {
74-
master.copyFileToContainer(
74+
master.withCopyFileToContainer(
7575
MountableFile.forHostPath(copyFilePath),
7676
SEATUNNEL_HOME + "/plugins/jdbc/lib");
7777
});

0 commit comments

Comments
 (0)