[Hotfix][APP] Fix job config file generation path error in windows (#140

) * [fit][seatunnel-app] Modify configuration file generation path rules to adapt to windows and linux * [refactor][APP] Modify exception logs
apache · Oct 27, 2023 · 8d0c436 · 8d0c436
1 parent cfc5870
commit 8d0c436
Showing 1 changed file with 12 additions and 3 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
@@ -29,6 +29,7 @@
 import org.apache.seatunnel.app.thirdparty.metrics.IEngineMetricsExtractor;
 import org.apache.seatunnel.common.config.Common;
 import org.apache.seatunnel.common.config.DeployMode;
+import org.apache.seatunnel.common.utils.ExceptionUtils;
 import org.apache.seatunnel.engine.client.SeaTunnelClient;
 import org.apache.seatunnel.engine.client.job.ClientJobProxy;
 import org.apache.seatunnel.engine.client.job.JobExecutionEnvironment;
@@ -76,7 +77,8 @@ public Result<Long> jobExecute(Integer userId, Long jobDefineId) {
 
     public String writeJobConfigIntoConfFile(String jobConfig, Long jobDefineId) {
         String projectRoot = System.getProperty("user.dir");
-        String filePath = projectRoot + "\\profile\\" + jobDefineId + ".conf";
+        String filePath =
+                projectRoot + File.separator + "profile" + File.separator + jobDefineId + ".conf";
         try {
             File file = new File(filePath);
             if (!file.exists()) {
@@ -120,6 +122,7 @@ public Long executeJobBySeaTunnel(Integer userId, String filePath, Long jobInsta
                     });
 
         } catch (ExecutionException | InterruptedException e) {
+            ExceptionUtils.getMessage(e);
             throw new RuntimeException(e);
         }
         return jobInstanceId;
@@ -189,8 +192,14 @@ public Result<Void> jobStore(Integer userId, Long jobInstanceId) {
         JobInstance jobInstance = jobInstanceDao.getJobInstance(jobInstanceId);
 
         String projectRoot = System.getProperty("user.dir");
-        String filePath = projectRoot + "\\profile\\" + jobInstance.getJobDefineId() + ".conf";
-
+        String filePath =
+                projectRoot
+                        + File.separator
+                        + "profile"
+                        + File.separator
+                        + jobInstance.getJobDefineId()
+                        + ".conf";
+        log.info("jobStore filePath:{}", filePath);
         SeaTunnelEngineProxy.getInstance()
                 .restoreJob(filePath, jobInstanceId, Long.valueOf(jobInstance.getJobEngineId()));
         return Result.success();