From 8e474a36301164d66d0d501c5471fd0e919ce288 Mon Sep 17 00:00:00 2001 From: Gabriel Date: Fri, 22 Nov 2024 13:09:37 +0800 Subject: [PATCH] [minor](log) Add more information in error message --- be/src/runtime/fragment_mgr.cpp | 20 +++++++++++++------- 1 file changed, 13 insertions(+), 7 deletions(-) diff --git a/be/src/runtime/fragment_mgr.cpp b/be/src/runtime/fragment_mgr.cpp index 5a8ea2377aa80f..16b75794511c06 100644 --- a/be/src/runtime/fragment_mgr.cpp +++ b/be/src/runtime/fragment_mgr.cpp @@ -751,7 +751,9 @@ std::string FragmentMgr::dump_pipeline_tasks(TUniqueId& query_id) { if (auto q_ctx = _get_or_erase_query_ctx(query_id)) { return q_ctx->print_all_pipeline_context(); } else { - return fmt::format("Query context (query id = {}) not found. \n", print_id(query_id)); + return fmt::format( + "Dump pipeline tasks failed: Query context (query id = {}) not found. \n", + print_id(query_id)); } } @@ -1266,8 +1268,10 @@ Status FragmentMgr::send_filter_size(const PSendFilterSizeRequest* request) { if (auto q_ctx = _get_or_erase_query_ctx(query_id)) { query_ctx = q_ctx; } else { - return Status::EndOfFile("Query context (query-id: {}) not found, maybe finished", - queryid.to_string()); + return Status::EndOfFile( + "Send filter size failed: Query context (query-id: {}) not found, maybe " + "finished", + queryid.to_string()); } } @@ -1288,8 +1292,9 @@ Status FragmentMgr::sync_filter_size(const PSyncFilterSizeRequest* request) { if (auto q_ctx = _get_or_erase_query_ctx(query_id)) { query_ctx = q_ctx; } else { - return Status::InvalidArgument("Query context (query-id: {}) not found", - queryid.to_string()); + return Status::InvalidArgument( + "Sync filter size failed: Query context (query-id: {}) not found", + queryid.to_string()); } } return query_ctx->runtime_filter_mgr()->sync_filter_size(request); @@ -1308,8 +1313,9 @@ Status FragmentMgr::merge_filter(const PMergeFilterRequest* request, if (auto q_ctx = _get_or_erase_query_ctx(query_id)) { query_ctx = q_ctx; } else { - return Status::InvalidArgument("Query context (query-id: {}) not found", - queryid.to_string()); + return Status::InvalidArgument( + "Merge filter size failed: Query context (query-id: {}) not found", + queryid.to_string()); } } SCOPED_ATTACH_TASK(query_ctx.get());