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 8f5e737cbfcd22b5116433a702b020d7efa2fac6
Author: abmdocrt <yukang.lian2...@gmail.com>
AuthorDate: Wed Feb 7 20:17:53 2024 +0800

    [Enhancement](wal) Optimize group commit manager log (#30849)
---
 be/src/olap/wal/wal_manager.cpp     | 1 +
 be/src/runtime/group_commit_mgr.cpp | 4 +++-
 2 files changed, 4 insertions(+), 1 deletion(-)

diff --git a/be/src/olap/wal/wal_manager.cpp b/be/src/olap/wal/wal_manager.cpp
index 601a9bc5b4a..59e87fba9c1 100644
--- a/be/src/olap/wal/wal_manager.cpp
+++ b/be/src/olap/wal/wal_manager.cpp
@@ -403,6 +403,7 @@ Status WalManager::_update_wal_dir_info_thread() {
     while (!_stop.load()) {
         static_cast<void>(_wal_dirs_info->update_all_wal_dir_limit());
         static_cast<void>(_wal_dirs_info->update_all_wal_dir_used());
+        LOG_EVERY_N(INFO, 100) << "Scheduled(every 10s) WAL info: " << 
get_wal_dirs_info_string();
         std::this_thread::sleep_for(std::chrono::milliseconds(100));
     }
     return Status::OK();
diff --git a/be/src/runtime/group_commit_mgr.cpp 
b/be/src/runtime/group_commit_mgr.cpp
index d98bf9efd1b..b793efa6e74 100644
--- a/be/src/runtime/group_commit_mgr.cpp
+++ b/be/src/runtime/group_commit_mgr.cpp
@@ -420,7 +420,9 @@ Status GroupCommitTable::_finish_group_commit_load(int64_t 
db_id, int64_t table_
        << ", txn_id=" << txn_id << ", instance_id=" << print_id(instance_id)
        << ", exec_plan_fragment status=" << status.to_string()
        << ", commit/abort txn rpc status=" << st.to_string()
-       << ", commit/abort txn status=" << result_status.to_string();
+       << ", commit/abort txn status=" << result_status.to_string()
+       << ", block queue pre allocated size is " << 
load_block_queue->block_queue_pre_allocated()
+       << ", wal space info:" << 
ExecEnv::GetInstance()->wal_mgr()->get_wal_dirs_info_string();
     if (state) {
         if (!state->get_error_log_file_path().empty()) {
             ss << ", error_url=" << state->get_error_log_file_path();


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org

Reply via email to