This is an automated email from the ASF dual-hosted git repository.
diwu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 2dc7d82affa [Chore](Job)print log before task execute (#28962)
2dc7d82affa is described below
commit 2dc7d82affa6a4ca47f749cfdcba8b2db6ef8c9a
Author: Calvin Kirs <[email protected]>
AuthorDate: Mon Dec 25 16:55:59 2023 +0800
[Chore](Job)print log before task execute (#28962)
---
.../java/org/apache/doris/job/executor/DefaultTaskExecutorHandler.java | 3 ++-
.../main/java/org/apache/doris/job/executor/DispatchTaskHandler.java | 2 ++
2 files changed, 4 insertions(+), 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
index a07e248af6d..befa8cc35fc 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<T extends
AbstractTask> 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 cb0a393d917..e5933d133cb 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<T extends AbstractJob>
implements WorkHandler<T
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) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
