database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[Enhancement](wal) Optimize group commit manager log (#30849)

Browse Source
This commit is contained in:
abmdocrt
2024-02-07 20:17:53 +08:00
committed by yiguolei
parent 36d753eacb
commit 22cc8342d4
2 changed files with 4 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
be/src/olap/wal/wal_manager.cpp
View File

@ -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();

4
be/src/runtime/group_commit_mgr.cpp
View File

@ -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();