This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new fc64dd59177 [chore](cloud) Add cloud meta mgr timeout counter (#51836)
fc64dd59177 is described below
commit fc64dd59177c84f8b989f2e48d08d23668c2798a
Author: Gavin Chou <[email protected]>
AuthorDate: Wed Jun 18 17:46:56 2025 +0800
[chore](cloud) Add cloud meta mgr timeout counter (#51836)
---
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 fce3c0c7886..5c4b8c179c5 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:
@@ -399,6 +402,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]
