This is an automated email from the ASF dual-hosted git repository.
yiguolei 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 5c1e1c42b2a [Enhancement](group commit) Optimize group commit block
sink wal disk space log #30811
5c1e1c42b2a is described below
commit 5c1e1c42b2a969b2c037e19956d25420b09e1a86
Author: abmdocrt <[email protected]>
AuthorDate: Mon Feb 5 10:15:05 2024 +0800
[Enhancement](group commit) Optimize group commit block sink wal disk space
log #30811
---
be/src/vec/sink/group_commit_block_sink.cpp | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/be/src/vec/sink/group_commit_block_sink.cpp
b/be/src/vec/sink/group_commit_block_sink.cpp
index f10becd056b..aee7138eba8 100644
--- a/be/src/vec/sink/group_commit_block_sink.cpp
+++ b/be/src/vec/sink/group_commit_block_sink.cpp
@@ -247,7 +247,9 @@ Status GroupCommitBlockSink::_add_blocks(RuntimeState*
state,
if (_group_commit_mode == TGroupCommitMode::SYNC_MODE) {
LOG(INFO) << "Load id=" << print_id(_state->query_id())
<< ", use group commit label=" <<
_load_block_queue->label
- << " will not write wal because wal disk space
usage reach max limit";
+ << " will not write wal because wal disk space
usage reach max "
+ "limit. Detail info: "
+ <<
_state->exec_env()->wal_mgr()->get_wal_dirs_info_string();
}
}
_state->set_import_label(_load_block_queue->label);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]