(seatunnel-web) branch main updated: [Bug] [Seatunnel-web] Seatunnel-web always requires the cluster name to be seatunnel (#174)

[lidongdai]

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

lidongdai pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/seatunnel-web.git


The following commit(s) were added to refs/heads/main by this push:
     new 6d99a72c [Bug] [Seatunnel-web] Seatunnel-web always requires the 
cluster name to be seatunnel (#174)
6d99a72c is described below

commit 6d99a72c1c9ba207e4fc36c15be288bdc8d04239
Author: Mohammad Arshad <ars...@apache.org>
AuthorDate: Thu Aug 8 17:01:35 2024 +0530

    [Bug] [Seatunnel-web] Seatunnel-web always requires the cluster name to be 
seatunnel (#174)
---
 .../apache/seatunnel/app/service/impl/JobExecutorServiceImpl.java   | 6 +-----
 1 file changed, 1 insertion(+), 5 deletions(-)

diff --git 
a/seatunnel-server/seatunnel-app/src/main/java/org/apache/seatunnel/app/service/impl/JobExecutorServiceImpl.java
 
b/seatunnel-server/seatunnel-app/src/main/java/org/apache/seatunnel/app/service/impl/JobExecutorServiceImpl.java
index 90d57d21..29a07c12 100644
--- 
a/seatunnel-server/seatunnel-app/src/main/java/org/apache/seatunnel/app/service/impl/JobExecutorServiceImpl.java
+++ 
b/seatunnel-server/seatunnel-app/src/main/java/org/apache/seatunnel/app/service/impl/JobExecutorServiceImpl.java
@@ -158,14 +158,10 @@ public class JobExecutorServiceImpl implements 
IJobExecutorService {
 
     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);