[fix](pipeline) Fix cancel_query locks nothing #23815

2023-09-04 11:50:24 +08:00
parent 3e00d62780
commit 201c0cc4ef
1 changed files with 1 additions and 1 deletions
--- a/be/src/runtime/fragment_mgr.cpp
+++ b/be/src/runtime/fragment_mgr.cpp
@ -849,7 +849,7 @@ void FragmentMgr::_set_scan_concurrency(const Param& params, QueryContext* query

 void FragmentMgr::cancel_query(const TUniqueId& query_id, const PPlanFragmentCancelReason& reason,
                               const std::string& msg) {
-    std::unique_lock<std::mutex> state_lock;
+    std::unique_lock<std::mutex> state_lock(_lock);
    return cancel_query_unlocked(query_id, reason, state_lock, msg);
 }