simple fix for cancel core block dep is released when call

apache · May 15, 2024 · 4ba15b2 · 4ba15b2
1 parent e4b9ded
commit 4ba15b2
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/be/src/pipeline/pipeline_x/pipeline_x_task.h b/be/src/pipeline/pipeline_x/pipeline_x_task.h
@@ -139,6 +139,9 @@ class PipelineXTask : public PipelineTask {
     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;