This is an automated email from the ASF dual-hosted git repository.

dataroaring 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 72748c229a update (#14215)
72748c229a is described below

commit 72748c229a9ea4ebbfb1d94af9b60f37df3e5441
Author: zhannngchen <48427519+zhannngc...@users.noreply.github.com>
AuthorDate: Sun Nov 13 12:31:42 2022 +0800

    update (#14215)
---
 be/src/common/config.h              | 2 +-
 be/src/runtime/load_channel_mgr.cpp | 4 ++--
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/be/src/common/config.h b/be/src/common/config.h
index aa193300a7..836c57d8dc 100644
--- a/be/src/common/config.h
+++ b/be/src/common/config.h
@@ -486,7 +486,7 @@ CONF_Int32(load_process_max_memory_limit_percent, "50");    
     // 50%
 // soft limit which can trigger the memtable flush for the load channel who
 // consumes lagest memory size before we reach the hard limit. The soft limit
 // might avoid all load jobs hang at the same time.
-CONF_Int32(load_process_soft_mem_limit_percent, "50");
+CONF_Int32(load_process_soft_mem_limit_percent, "80");
 
 // result buffer cancelled time (unit: second)
 CONF_mInt32(result_buffer_cancelled_interval_time, "300");
diff --git a/be/src/runtime/load_channel_mgr.cpp 
b/be/src/runtime/load_channel_mgr.cpp
index 45c80c6169..d08104032d 100644
--- a/be/src/runtime/load_channel_mgr.cpp
+++ b/be/src/runtime/load_channel_mgr.cpp
@@ -182,7 +182,6 @@ Status LoadChannelMgr::_start_load_channels_clean() {
     {
         std::vector<UniqueId> need_delete_channel_ids;
         std::lock_guard<std::mutex> l(_lock);
-        VLOG_CRITICAL << "there are " << _load_channels.size() << " running 
load channels";
         int i = 0;
         for (auto& kv : _load_channels) {
             VLOG_CRITICAL << "load channel[" << i++ << "]: " << *(kv.second);
@@ -212,7 +211,8 @@ Status LoadChannelMgr::_start_load_channels_clean() {
     // on this Backend
     LOG(INFO) << "load mem consumption(bytes). limit: " << _load_hard_mem_limit
               << ", current: " << _mem_tracker->consumption()
-              << ", peak: " << _mem_tracker->peak_consumption();
+              << ", peak: " << _mem_tracker->peak_consumption()
+              << ", total running load channels: " << _load_channels.size();
 
     return Status::OK();
 }


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

Reply via email to