1

liugddx · Dec 25, 2023 · 20ed5df · 20ed5df
1 parent f248f97
commit 20ed5df
Show file tree

Hide file tree

Showing 2 changed files with 23 additions and 2 deletions.
diff --git a/...nel-engine-server/src/main/java/org/apache/seatunnel/engine/server/rest/RestConstant.java b/...nel-engine-server/src/main/java/org/apache/seatunnel/engine/server/rest/RestConstant.java
@@ -55,4 +55,6 @@ public class RestConstant {
             "/hazelcast/rest/maps/system-monitoring-information";
 
     public static final String STOP_JOB_URL = "/hazelcast/rest/maps/stop-job";
+
+    public static final String GET_LOG = "/hazelcast/rest/maps/log";
 }
diff --git a/...er/src/main/java/org/apache/seatunnel/engine/server/rest/RestHttpGetCommandProcessor.java b/...er/src/main/java/org/apache/seatunnel/engine/server/rest/RestHttpGetCommandProcessor.java
@@ -55,6 +55,10 @@
 import com.hazelcast.map.IMap;
 import com.hazelcast.spi.impl.NodeEngine;
 
+import java.io.IOException;
+import java.nio.file.Files;
+import java.nio.file.Path;
+import java.nio.file.Paths;
 import java.text.SimpleDateFormat;
 import java.util.Arrays;
 import java.util.Comparator;
@@ -69,7 +73,7 @@
 import static org.apache.seatunnel.engine.server.rest.RestConstant.RUNNING_JOBS_URL;
 import static org.apache.seatunnel.engine.server.rest.RestConstant.RUNNING_JOB_URL;
 import static org.apache.seatunnel.engine.server.rest.RestConstant.SYSTEM_MONITORING_INFORMATION;
-
+import static org.apache.seatunnel.engine.server.rest.RestConstant.GET_LOG;
 public class RestHttpGetCommandProcessor extends HttpCommandProcessor<HttpGetCommand> {
 
     private final Log4j2HttpGetCommandProcessor original;
@@ -105,7 +109,9 @@ public void handle(HttpGetCommand httpGetCommand) {
                 handleJobInfoById(httpGetCommand, uri);
             } else if (uri.startsWith(SYSTEM_MONITORING_INFORMATION)) {
                 getSystemMonitoringInformation(httpGetCommand);
-            } else {
+            } else if (uri.startsWith(GET_LOG)) {
+                handleLog(httpGetCommand);
+            }else {
                 original.handle(httpGetCommand);
             }
         } catch (IndexOutOfBoundsException e) {
@@ -159,6 +165,19 @@ private void getSystemMonitoringInformation(HttpGetCommand command) {
         this.prepareResponse(command, jsonValues);
     }
 
+    private void handleLog(HttpGetCommand command) throws IOException {
+
+        String logPath = System.getProperty("seatunnel.logs.path");
+        String logName = System.getProperty("seatunnel.logs.file_name")+".log";
+        Path path = Paths.get(logPath, logName);
+        if (!Files.exists(path)) {
+            this.prepareResponse(command, new JsonObject());
+            return;
+        }
+        byte[] logBytes = Files.readAllBytes(path);
+        this.prepareResponse(command, new String(logBytes));
+    }
+
     private void handleRunningJobsInfo(HttpGetCommand command) {
         IMap<Long, JobInfo> values =
                 this.textCommandService