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 need_delete_channel_ids; std::lock_guard 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(); }