Merge branch 'dev' into dockerfile

liunaijie · Nov 3, 2023 · f6eb7a2 · f6eb7a2
2 parents 99abcdc + 70cca95
commit f6eb7a2
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 0 deletions.
diff --git a/...org/apache/seatunnel/e2e/common/container/seatunnel/ConnectorPackageServiceContainer.java b/...org/apache/seatunnel/e2e/common/container/seatunnel/ConnectorPackageServiceContainer.java
@@ -184,6 +184,16 @@ protected String getConnectorType() {
         return "seatunnel";
     }
 
+    @Override
+    protected String getSavePointCommand() {
+        return "-s";
+    }
+
+    @Override
+    protected String getRestoreCommand() {
+        return "-r";
+    }
+
     @Override
     protected String getConnectorNamePrefix() {
         return "connector-";

diff --git a/...connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/RestApiIT.java b/...connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/RestApiIT.java
@@ -17,6 +17,8 @@
 
 package org.apache.seatunnel.engine.e2e;
 
+import org.apache.seatunnel.common.config.Common;
+import org.apache.seatunnel.common.config.DeployMode;
 import org.apache.seatunnel.engine.client.SeaTunnelClient;
 import org.apache.seatunnel.engine.client.job.ClientJobExecutionEnvironment;
 import org.apache.seatunnel.engine.client.job.ClientJobProxy;
@@ -61,6 +63,7 @@ void beforeClass() throws Exception {
         SeaTunnelConfig seaTunnelConfig = ConfigProvider.locateAndGetSeaTunnelConfig();
         seaTunnelConfig.getHazelcastConfig().setClusterName(testClusterName);
         hazelcastInstance = SeaTunnelServerStarter.createHazelcastInstance(seaTunnelConfig);
+        Common.setDeployMode(DeployMode.CLIENT);
         String filePath = TestUtils.getResource("stream_fakesource_to_file.conf");
         JobConfig jobConfig = new JobConfig();
         jobConfig.setName("fake_to_file");