This is an automated email from the ASF dual-hosted git repository.
gabriellee pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-3.0 by this push:
new fe0b4378949 branch-3.0: [minor](log) Add more information in error
message #44452 (#44474)
fe0b4378949 is described below
commit fe0b437894932aaf76c061ff2604528d8aa2d3e2
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Tue Nov 26 10:49:35 2024 +0800
branch-3.0: [minor](log) Add more information in error message #44452
(#44474)
Cherry-picked from #44452
Co-authored-by: Gabriel <[email protected]>
---
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 d3fe8aec1f4..fbbc079c30a 100644
--- a/be/src/runtime/fragment_mgr.cpp
+++ b/be/src/runtime/fragment_mgr.cpp
@@ -790,7 +790,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));
}
}
@@ -1235,8 +1237,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());
}
}
@@ -1257,8 +1261,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);
@@ -1277,8 +1282,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());
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
