[minor](log) Add more information in error message (#44452)

apache · Nov 22, 2024 · 76c1332 · 76c1332
1 parent 1ffecfd
commit 76c1332
Showing 1 changed file with 13 additions and 7 deletions.
diff --git 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());