This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-3.0 by this push:
new 2539f2eef0a branch-3.0:[fix](timer) Fix task execution timer (#49939)
(#49976)
2539f2eef0a is described below
commit 2539f2eef0aae0cd72597c84d2d7693b5beb48c0
Author: Gabriel <liwenqi...@selectdb.com>
AuthorDate: Mon Apr 14 10:49:54 2025 +0800
branch-3.0:[fix](timer) Fix task execution timer (#49939) (#49976)
pick #49939
Execution timer is needed to make a task yield after a time slice.
---
be/src/pipeline/pipeline_task.cpp | 2 ++
1 file changed, 2 insertions(+)
diff --git a/be/src/pipeline/pipeline_task.cpp
b/be/src/pipeline/pipeline_task.cpp
index 6bd95ff3d18..835387bc84c 100644
--- a/be/src/pipeline/pipeline_task.cpp
+++ b/be/src/pipeline/pipeline_task.cpp
@@ -331,6 +331,7 @@ Status PipelineTask::execute(bool* eos) {
}
});
+ SCOPED_RAW_TIMER(&time_spent);
if (_wake_up_early) {
*eos = true;
_eos = true;
@@ -350,6 +351,7 @@ Status PipelineTask::execute(bool* eos) {
_task_profile->add_info_string("TaskState", "Runnable");
_task_profile->add_info_string("BlockedByDependency", "");
while (!_fragment_context->is_canceled()) {
+ SCOPED_RAW_TIMER(&time_spent);
if (_is_blocked()) {
return Status::OK();
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
