update (#14215)
This commit is contained in:
@ -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");
|
||||
|
||||
@ -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();
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user