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 7dbec0d9b2f [bugfix](becore) pipeline core when workload group
shutdown (#50743)
7dbec0d9b2f is described below
commit 7dbec0d9b2f116eeefec166390baa106aba39038
Author: yiguolei <[email protected]>
AuthorDate: Fri May 9 14:29:41 2025 +0800
[bugfix](becore) pipeline core when workload group shutdown (#50743)
### What problem does this PR solve?
1. When workload group shutdown, it will shutdown pipeline task
scheduler.
2. In pipelinetask scheduler, it will first call task queue.close, in
this method it will deconstruct priority task queue.
3. But at this time, the pipeline task thread is not stopped.
So that it will core.
Related PR: #xxx
---
be/src/pipeline/task_queue.cpp | 2 --
1 file changed, 2 deletions(-)
diff --git a/be/src/pipeline/task_queue.cpp b/be/src/pipeline/task_queue.cpp
index f1621b941a0..f59707d872f 100644
--- a/be/src/pipeline/task_queue.cpp
+++ b/be/src/pipeline/task_queue.cpp
@@ -149,8 +149,6 @@ void MultiCoreTaskQueue::close() {
for (int i = 0; i < _core_size; ++i) {
(*_prio_task_queue_list)[i]->close();
}
- std::atomic_store(&_prio_task_queue_list,
-
std::shared_ptr<std::vector<std::unique_ptr<PriorityTaskQueue>>>(nullptr));
}
PipelineTask* MultiCoreTaskQueue::take(int core_id) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
