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 7ecfda572a6 [improvement](group_commit) Add bvar to monitor the count
of replaying wal fail on group commit (#30941)
7ecfda572a6 is described below
commit 7ecfda572a671be68d1bda0df545e0c5657085ab
Author: huanghaibin <[email protected]>
AuthorDate: Thu Feb 8 11:51:14 2024 +0800
[improvement](group_commit) Add bvar to monitor the count of replaying wal
fail on group commit (#30941)
---
be/src/olap/wal/wal_table.cpp | 3 +++
1 file changed, 3 insertions(+)
diff --git a/be/src/olap/wal/wal_table.cpp b/be/src/olap/wal/wal_table.cpp
index 9b2d1338f24..cb5f53508e0 100644
--- a/be/src/olap/wal/wal_table.cpp
+++ b/be/src/olap/wal/wal_table.cpp
@@ -37,6 +37,8 @@
namespace doris {
+bvar::Adder<uint64_t> wal_fail("group_commit_wal_fail");
+
WalTable::WalTable(ExecEnv* exec_env, int64_t db_id, int64_t table_id)
: _exec_env(exec_env), _db_id(db_id), _table_id(table_id) {
_http_stream_action = std::make_shared<HttpStreamAction>(exec_env);
@@ -99,6 +101,7 @@ Status WalTable::_relay_wal_one_by_one() {
wal_info->add_retry_num();
auto st = _replay_wal_internal(wal_info->get_wal_path());
if (!st.ok()) {
+ doris::wal_fail << 1;
LOG(WARNING) << "failed to replay wal=" << wal_info->get_wal_path()
<< ", st=" << st.to_string();
if (!st.is<ErrorCode::NOT_FOUND>()) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
