1

xinyiZzz · Jan 2, 2025 · 3fe9ee6 · 3fe9ee6
1 parent 04d7927
commit 3fe9ee6
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 2 deletions.
diff --git a/be/src/runtime/buffer_control_block.cpp b/be/src/runtime/buffer_control_block.cpp
@@ -170,7 +170,10 @@ BufferControlBlock::BufferControlBlock(TUniqueId id, int buffer_size, RuntimeSta
 }
 
 BufferControlBlock::~BufferControlBlock() {
-    cancel(Status::Cancelled("Cancelled"));
+    cancel(Status::Cancelled(fmt::format(
+            "BufferControlBlock is destructed, this is not the expected path, the correct path is "
+            "ResultBufferMgr::cancel before the destructor, fragmentId: {}",
+            print_id(_fragment_id))));
 }
 
 Status BufferControlBlock::init() {

diff --git a/be/src/runtime/result_buffer_mgr.cpp b/be/src/runtime/result_buffer_mgr.cpp
@@ -211,7 +211,8 @@ void ResultBufferMgr::cancel_thread() {
 
         // cancel query
         for (const auto& id : query_to_cancel) {
-            cancel(id, Status::TimedOut("Query tiemout"));
+            cancel(id, Status::Cancelled(fmt::format(
+                               "Clean up expired BufferControlBlock, queryId: {}", print_id(id))));
         }
     } while (!_stop_background_threads_latch.wait_for(std::chrono::seconds(1)));