[refactor][APP]

Modify exception logs
apache · Oct 26, 2023 · dae5f00 · dae5f00
1 parent 7c00d3a
commit dae5f00
Showing 1 changed file with 2 additions and 1 deletion.
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;
@@ -121,7 +122,7 @@ public Long executeJobBySeaTunnel(Integer userId, String filePath, Long jobInsta
                     });
 
         } catch (ExecutionException | InterruptedException e) {
-            log.error("executeJobBySeaTunnel error:{}", e.getMessage());
+            ExceptionUtils.getMessage(e);
             throw new RuntimeException(e);
         }
         return jobInstanceId;