This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
commit 6217de2f108e8a15cc6047d8d3bbdd91c1dfba1b
Author: huanghaibin <284824...@qq.com>
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: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
