[Improve][Zeta] Add more detailed log output. (#4446)

apache · Mar 31, 2023 · d7ee509 · d7ee509
1 parent e05ceb7
commit d7ee509
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/...-engine-server/src/main/java/org/apache/seatunnel/engine/server/TaskExecutionService.java b/...-engine-server/src/main/java/org/apache/seatunnel/engine/server/TaskExecutionService.java
@@ -248,7 +248,7 @@ public TaskDeployState deployTask(@NonNull TaskGroupImmutableInformation taskImm
                 taskGroup =
                         nodeEngine.getSerializationService().toObject(taskImmutableInfo.getGroup());
             }
-            logger.fine(
+            logger.info(
                     String.format(
                             "deploying task %s, executionId [%s]",
                             taskGroup.getTaskGroupLocation(), taskImmutableInfo.getExecutionId()));
@@ -287,6 +287,10 @@ public PassiveCompletableFuture<TaskExecutionState> deployLocalTask(
         CompletableFuture<TaskExecutionState> resultFuture = new CompletableFuture<>();
         try {
             taskGroup.init();
+            logger.info(
+                    String.format(
+                            "deploying TaskGroup %s init success",
+                            taskGroup.getTaskGroupLocation()));
             Collection<Task> tasks = taskGroup.getTasks();
             CompletableFuture<Void> cancellationFuture = new CompletableFuture<>();
             TaskGroupExecutionTracker executionTracker =
@@ -322,6 +326,9 @@ public PassiveCompletableFuture<TaskExecutionState> deployLocalTask(
             submitThreadShareTask(executionTracker, byCooperation.get(true));
             submitBlockingTask(executionTracker, byCooperation.get(false));
             taskGroup.setTasksContext(taskExecutionContextMap);
+            logger.info(
+                    String.format(
+                            "deploying TaskGroup %s success", taskGroup.getTaskGroupLocation()));
         } catch (Throwable t) {
             logger.severe(ExceptionUtils.getMessage(t));
             resultFuture.completeExceptionally(t);