(seatunnel) branch dev updated: [Fix] Fix `ConnectorPackageServiceContainer` miss implement getSavePointCommand/getRestoreCommand (#5780)

[wenjun]

This is an automated email from the ASF dual-hosted git repository.

wenjun 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 70cca95687 [Fix] Fix `ConnectorPackageServiceContainer` miss implement 
getSavePointCommand/getRestoreCommand (#5780)
70cca95687 is described below

commit 70cca956876f165c2cc12f7a193cf87d6187defe
Author: Jia Fan <fanjiaemi...@qq.com>
AuthorDate: Fri Nov 3 17:31:07 2023 +0800

    [Fix] Fix `ConnectorPackageServiceContainer` miss implement 
getSavePointCommand/getRestoreCommand (#5780)
---
 .../container/seatunnel/ConnectorPackageServiceContainer.java  | 10 ++++++++++
 .../test/java/org/apache/seatunnel/engine/e2e/RestApiIT.java   |  3 +++
 2 files changed, 13 insertions(+)

diff --git 
a/seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/container/seatunnel/ConnectorPackageServiceContainer.java
 
b/seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/container/seatunnel/ConnectorPackageServiceContainer.java
index 5c14651d5e..4e30d2c92b 100644
--- 
a/seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/container/seatunnel/ConnectorPackageServiceContainer.java
+++ 
b/seatunnel-e2e/seatunnel-e2e-common/src/test/java/org/apache/seatunnel/e2e/common/container/seatunnel/ConnectorPackageServiceContainer.java
@@ -184,6 +184,16 @@ public class ConnectorPackageServiceContainer extends 
AbstractTestContainer {
         return "seatunnel";
     }
 
+    @Override
+    protected String getSavePointCommand() {
+        return "-s";
+    }
+
+    @Override
+    protected String getRestoreCommand() {
+        return "-r";
+    }
+
     @Override
     protected String getConnectorNamePrefix() {
         return "connector-";
diff --git 
a/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/RestApiIT.java
 
b/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/RestApiIT.java
index c74e18578f..ed0118be1c 100644
--- 
a/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/RestApiIT.java
+++ 
b/seatunnel-e2e/seatunnel-engine-e2e/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 @@ public class RestApiIT {
         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");