From 4e86ec552f8cb782a3cd1c83965a85135ede6fa3 Mon Sep 17 00:00:00 2001 From: Zou Xinyi Date: Thu, 2 Jan 2025 14:53:10 +0800 Subject: [PATCH] 3 --- be/src/runtime/buffer_control_block.cpp | 4 ++-- be/src/runtime/result_buffer_mgr.cpp | 4 ++-- 2 files changed, 4 insertions(+), 4 deletions(-) diff --git a/be/src/runtime/buffer_control_block.cpp b/be/src/runtime/buffer_control_block.cpp index 836b6b3280a0d0..be8363fb3f2c1f 100644 --- a/be/src/runtime/buffer_control_block.cpp +++ b/be/src/runtime/buffer_control_block.cpp @@ -170,10 +170,10 @@ BufferControlBlock::BufferControlBlock(TUniqueId id, int buffer_size, RuntimeSta } BufferControlBlock::~BufferControlBlock() { - cancel(Status::Cancelled(fmt::format( + cancel(Status::Cancelled( "BufferControlBlock is destructed, this is not the expected path, the correct path is " "ResultBufferMgr::cancel before the destructor, fragmentId: {}", - print_id(_fragment_id)))); + 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 index e33cc766bc03f3..fb2946ecd345b9 100644 --- a/be/src/runtime/result_buffer_mgr.cpp +++ b/be/src/runtime/result_buffer_mgr.cpp @@ -211,8 +211,8 @@ void ResultBufferMgr::cancel_thread() { // cancel query for (const auto& id : query_to_cancel) { - cancel(id, Status::Cancelled(fmt::format( - "Clean up expired BufferControlBlock, queryId: {}", print_id(id)))); + cancel(id, Status::Cancelled("Clean up expired BufferControlBlock, queryId: {}", + print_id(id))); } } while (!_stop_background_threads_latch.wait_for(std::chrono::seconds(1)));