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
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new cdc950f2c3f [improvement](spill) improve spill log printing
cdc950f2c3f is described below
commit cdc950f2c3fd2f9b6f1fcd891419034a159cc9af
Author: yiguolei <[email protected]>
AuthorDate: Sun May 12 19:33:27 2024 +0800
[improvement](spill) improve spill log printing
---
be/src/pipeline/pipeline_x/pipeline_x_task.cpp | 13 ++++++-------
be/src/runtime/workload_group/workload_group_manager.cpp | 4 ++--
2 files changed, 8 insertions(+), 9 deletions(-)
diff --git a/be/src/pipeline/pipeline_x/pipeline_x_task.cpp
b/be/src/pipeline/pipeline_x/pipeline_x_task.cpp
index 760fbd385e6..af1e3912eb4 100644
--- a/be/src/pipeline/pipeline_x/pipeline_x_task.cpp
+++ b/be/src/pipeline/pipeline_x/pipeline_x_task.cpp
@@ -319,7 +319,7 @@ bool PipelineXTask::should_revoke_memory(RuntimeState*
state, int64_t revocable_
wg->check_mem_used(&is_wg_mem_low_water_mark, &is_wg_mem_high_water_mark);
if (is_wg_mem_high_water_mark) {
if (revocable_mem_bytes > min_revocable_mem_bytes) {
- LOG_EVERY_N(INFO, 10) << "revoke memory, hight water mark";
+ VLOG_DEBUG << "revoke memory, hight water mark";
return true;
}
return false;
@@ -339,12 +339,11 @@ bool PipelineXTask::should_revoke_memory(RuntimeState*
state, int64_t revocable_
mem_limit_of_op = query_weighted_limit / big_memory_operator_num;
}
- LOG_EVERY_N(INFO, 10) << "revoke memory, low water mark,
revocable_mem_bytes: "
- <<
PrettyPrinter::print_bytes(revocable_mem_bytes)
- << ", mem_limit_of_op: "
- << PrettyPrinter::print_bytes(mem_limit_of_op)
- << ", min_revocable_mem_bytes: "
- <<
PrettyPrinter::print_bytes(min_revocable_mem_bytes);
+ VLOG_DEBUG << "revoke memory, low water mark, revocable_mem_bytes: "
+ << PrettyPrinter::print_bytes(revocable_mem_bytes)
+ << ", mem_limit_of_op: " <<
PrettyPrinter::print_bytes(mem_limit_of_op)
+ << ", min_revocable_mem_bytes: "
+ << PrettyPrinter::print_bytes(min_revocable_mem_bytes);
return (revocable_mem_bytes > mem_limit_of_op ||
revocable_mem_bytes > min_revocable_mem_bytes);
} else {
diff --git a/be/src/runtime/workload_group/workload_group_manager.cpp
b/be/src/runtime/workload_group/workload_group_manager.cpp
index a0e0de75f36..153e9bab8ce 100644
--- a/be/src/runtime/workload_group/workload_group_manager.cpp
+++ b/be/src/runtime/workload_group/workload_group_manager.cpp
@@ -201,7 +201,7 @@ void WorkloadGroupMgr::refresh_wg_memory_info() {
PrettyPrinter::print(process_mem_used, TUnit::BYTES),
PrettyPrinter::print(sys_mem_available, TUnit::BYTES),
PrettyPrinter::print(all_queries_mem_used, TUnit::BYTES));
- VLOG_EVERY_N(1, 10) << debug_msg;
+ LOG_EVERY_T(INFO, 10) << debug_msg;
}
for (auto& wg : _workload_groups) {
@@ -264,7 +264,7 @@ void WorkloadGroupMgr::refresh_wg_memory_info() {
}
}
if (wg_mem_info.is_high_wartermark || wg_mem_info.is_low_wartermark) {
- VLOG_EVERY_N(1, 10) << debug_msg;
+ LOG_EVERY_T(INFO, 10) << debug_msg;
}
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
