[Chore][Zeta] Remove redundant code (#4489)

apache · Apr 4, 2023 · 17720b5 · 17720b5
1 parent 7d04b47
commit 17720b5
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 6 deletions.
diff --git a/...c/main/java/org/apache/seatunnel/core/starter/seatunnel/command/ClientExecuteCommand.java b/...c/main/java/org/apache/seatunnel/core/starter/seatunnel/command/ClientExecuteCommand.java
@@ -84,7 +84,7 @@ public void execute() throws CommandExecuteException {
                                 StringUtils.isNotEmpty(clusterName)
                                         ? clusterName
                                         : Constant.DEFAULT_SEATUNNEL_CLUSTER_NAME);
-                instance = createServerInLocal(clusterName);
+                instance = createServerInLocal(clusterName, seaTunnelConfig);
             }
             if (StringUtils.isNotEmpty(clusterName)) {
                 seaTunnelConfig.getHazelcastConfig().setClusterName(clusterName);
@@ -227,8 +227,8 @@ private void closeClient() {
         }
     }
 
-    private HazelcastInstance createServerInLocal(String clusterName) {
-        SeaTunnelConfig seaTunnelConfig = ConfigProvider.locateAndGetSeaTunnelConfig();
+    private HazelcastInstance createServerInLocal(
+            String clusterName, SeaTunnelConfig seaTunnelConfig) {
         seaTunnelConfig.getHazelcastConfig().setClusterName(clusterName);
         return HazelcastInstanceFactory.newHazelcastInstance(
                 seaTunnelConfig.getHazelcastConfig(),

diff --git a/...unnel-engine-client/src/main/java/org/apache/seatunnel/engine/client/SeaTunnelClient.java b/...unnel-engine-client/src/main/java/org/apache/seatunnel/engine/client/SeaTunnelClient.java
@@ -17,8 +17,6 @@
 
 package org.apache.seatunnel.engine.client;
 
-import org.apache.seatunnel.shade.com.fasterxml.jackson.databind.ObjectMapper;
-
 import org.apache.seatunnel.common.utils.JsonUtils;
 import org.apache.seatunnel.engine.client.job.JobClient;
 import org.apache.seatunnel.engine.client.job.JobExecutionEnvironment;
@@ -41,7 +39,6 @@
 import java.util.Set;
 
 public class SeaTunnelClient implements SeaTunnelClientInstance {
-    private static final ObjectMapper OBJECT_MAPPER = new ObjectMapper();
     private final SeaTunnelHazelcastClient hazelcastClient;
     @Getter private final JobClient jobClient;