This is an automated email from the ASF dual-hosted git repository. yiguolei pushed a commit to branch branch-2.1 in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1 by this push: new 4ba15b27cac simple fix for cancel core block dep is released when call 4ba15b27cac is described below commit 4ba15b27cacc86ae82fc0a5de8780eb27bd5f3fc Author: yiguolei <yiguo...@gmail.com> AuthorDate: Thu May 16 06:32:21 2024 +0800 simple fix for cancel core block dep is released when call --- be/src/pipeline/pipeline_x/pipeline_x_task.h | 3 +++ 1 file changed, 3 insertions(+) diff --git a/be/src/pipeline/pipeline_x/pipeline_x_task.h b/be/src/pipeline/pipeline_x/pipeline_x_task.h index 1f3dd9c3b71..03bafd47992 100644 --- a/be/src/pipeline/pipeline_x/pipeline_x_task.h +++ b/be/src/pipeline/pipeline_x/pipeline_x_task.h @@ -139,6 +139,9 @@ public: int task_id() const { return _index; }; void clear_blocking_state() { + // Another thread may call finalize to release all dependencies + // And then it will core. + std::unique_lock<std::mutex> lc(_release_lock); if (!_finished && get_state() != PipelineTaskState::PENDING_FINISH && _blocked_dep) { _blocked_dep->set_ready(); _blocked_dep = nullptr; --------------------------------------------------------------------- To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org For additional commands, e-mail: commits-h...@doris.apache.org