[Chore](Job)print log before task execute (#28962)

apache · Dec 25, 2023 · 2dc7d82 · 2dc7d82
1 parent 17917a0
commit 2dc7d82
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/job/executor/DefaultTaskExecutorHandler.java b/fe/fe-core/src/main/java/org/apache/doris/job/executor/DefaultTaskExecutorHandler.java
@@ -42,9 +42,10 @@ public void onEvent(ExecuteTaskEvent<T> executeTaskEvent) {
             return;
         }
         if (task.isCancelled()) {
-            log.info("task is canceled, ignore");
+            log.info("task is canceled, ignore. task id is {}", task.getTaskId());
             return;
         }
+        log.info("start to execute task, task id is {}", task.getTaskId());
         try {
             task.runTask();
         } catch (Exception e) {

diff --git a/fe/fe-core/src/main/java/org/apache/doris/job/executor/DispatchTaskHandler.java b/fe/fe-core/src/main/java/org/apache/doris/job/executor/DispatchTaskHandler.java
@@ -67,6 +67,8 @@ public void onEvent(TimerJobEvent<T> event) {
                 JobType jobType = event.getJob().getJobType();
                 for (AbstractTask task : tasks) {
                     disruptorMap.get(jobType).publishEvent(task, event.getJob().getJobConfig());
+                    log.info("dispatch timer job success, job id is {},  task id is {}",
+                            event.getJob().getJobId(), task.getTaskId());
                 }
             }
         } catch (Exception e) {