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

[improve](group-commit) Modify some log (#30842)

Browse Source
This commit is contained in:
meiyi
2024-02-06 13:52:20 +08:00
committed by yiguolei
parent 89695f43d4
commit 2667e10ba2
10 changed files with 50 additions and 72 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -65,8 +65,6 @@ Status LoadBlockQueue::add_block(RuntimeState* runtime_state,
_block_queue.push_back(block);
_data_bytes += block->bytes();
_all_block_queues_bytes->fetch_add(block->bytes(), std::memory_order_relaxed);
} else {
LOG(INFO) << "skip adding block to queue on txn " << txn_id;
}
if (write_wal || config::group_commit_wait_replay_wal_finish) {
auto st = _v_wal_writer->write_wal(block.get());
@ -405,7 +403,7 @@ Status GroupCommitTable::_finish_group_commit_load(int64_t db_id, int64_t table_
auto delete_st = _exec_env->wal_mgr()->delete_wal(
table_id, txn_id, load_block_queue->block_queue_pre_allocated());
if (!delete_st.ok()) {
LOG(WARNING) << "fail to delete wal " << txn_id;
LOG(WARNING) << "fail to delete wal " << txn_id << ", st=" << delete_st.to_string();
}
}
} else {
@ -545,7 +543,7 @@ bool LoadBlockQueue::has_enough_wal_disk_space(size_t pre_allocated) {
{
Status st = wal_mgr->get_wal_dir_available_size(_wal_base_path, &available_bytes);
if (!st.ok()) {
LOG(WARNING) << "get wal disk available size filed!";
LOG(WARNING) << "get wal dir available size failed, st=" << st.to_string();
}
}
if (pre_allocated < available_bytes) {