This is an automated email from the ASF dual-hosted git repository.

dataroaring 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 542cc933588 branch-3.0: [chore](cloud) Add cloud meta mgr timeout 
counter #51836 (#51882)
542cc933588 is described below

commit 542cc933588722d3e8de7d9bab0ade3111b90e15
Author: github-actions[bot] 
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Fri Jun 20 09:56:26 2025 +0800

    branch-3.0: [chore](cloud) Add cloud meta mgr timeout counter #51836 
(#51882)
    
    Cherry-picked from #51836
    
    Co-authored-by: Gavin Chou <[email protected]>
---
 be/src/cloud/cloud_meta_mgr.cpp | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git a/be/src/cloud/cloud_meta_mgr.cpp b/be/src/cloud/cloud_meta_mgr.cpp
index 2971ff33f8e..e4054bdd885 100644
--- a/be/src/cloud/cloud_meta_mgr.cpp
+++ b/be/src/cloud/cloud_meta_mgr.cpp
@@ -134,8 +134,11 @@ Status bthread_fork_join(const 
std::vector<std::function<Status()>>& tasks, int
 namespace {
 constexpr int kBrpcRetryTimes = 3;
 
-bvar::LatencyRecorder _get_rowset_latency("doris_CloudMetaMgr", "get_rowset");
+bvar::LatencyRecorder _get_rowset_latency("doris_cloud_meta_mgr_get_rowset");
 bvar::LatencyRecorder 
g_cloud_commit_txn_resp_redirect_latency("cloud_table_stats_report_latency");
+bvar::Adder<uint64_t> 
g_cloud_meta_mgr_rpc_timeout_count("cloud_meta_mgr_rpc_timeout_count");
+bvar::Window<bvar::Adder<uint64_t>> g_cloud_ms_rpc_timeout_count_window(
+        "cloud_meta_mgr_rpc_timeout_qps", &g_cloud_meta_mgr_rpc_timeout_count, 
30);
 
 class MetaServiceProxy {
 public:
@@ -404,6 +407,10 @@ Status retry_rpc(std::string_view op_name, const Request& 
req, Response* res,
             error_msg = res->status().msg();
         }
 
+        if (error_code == brpc::ERPCTIMEDOUT) {
+            g_cloud_meta_mgr_rpc_timeout_count << 1;
+        }
+
         ++retry_times;
         if (retry_times > config::meta_service_rpc_retry_times ||
             (retry_times > config::meta_service_rpc_timeout_retry_times &&


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to