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 index a07e248af6..befa8cc35f 100644 --- 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 class DefaultTaskExecutorHandler implements WorkH 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 index cb0a393d91..e5933d133c 100644 --- 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 class DispatchTaskHandler implements WorkHandler