[Bug] [Seatunnel-web] Seatunnel-web always requires the cluster name …

…to be seatunnel (#174)
apache · Aug 8, 2024 · 6d99a72 · 6d99a72
1 parent 43f045c
commit 6d99a72
Showing 1 changed file with 1 addition and 5 deletions.
diff --git a/...unnel-app/src/main/java/org/apache/seatunnel/app/service/impl/JobExecutorServiceImpl.java b/...unnel-app/src/main/java/org/apache/seatunnel/app/service/impl/JobExecutorServiceImpl.java
@@ -158,14 +158,10 @@ public void waitJobFinish(
 
     private SeaTunnelClient createSeaTunnelClient() {
         ClientConfig clientConfig = ConfigProvider.locateAndGetClientConfig();
-        clientConfig.setClusterName(getClusterName("seatunnel"));
+        clientConfig.setClusterName(clientConfig.getClusterName());
         return new SeaTunnelClient(clientConfig);
     }
 
-    public static String getClusterName(String testClassName) {
-        return testClassName;
-    }
-
     @Override
     public Result<Void> jobPause(Integer userId, Long jobInstanceId) {
         JobInstance jobInstance = jobInstanceDao.getJobInstance(jobInstanceId);