This is an automated email from the ASF dual-hosted git repository. morningman pushed a commit to branch branch-1.2-lts in repository https://gitbox.apache.org/repos/asf/doris.git
commit 05b4ccceb25e3387b478f72761794a4832853894 Author: Yongqiang YANG <[email protected]> AuthorDate: Wed May 3 17:48:13 2023 +0800 [improvement](load) log time consumed by waiting flush (#19226) --- be/src/runtime/load_channel_mgr.cpp | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/be/src/runtime/load_channel_mgr.cpp b/be/src/runtime/load_channel_mgr.cpp index 6470f56f70..97f6d6f58e 100644 --- a/be/src/runtime/load_channel_mgr.cpp +++ b/be/src/runtime/load_channel_mgr.cpp @@ -228,12 +228,15 @@ void LoadChannelMgr::_handle_mem_exceed_limit() { bool reducing_mem_on_hard_limit = false; std::vector<std::shared_ptr<LoadChannel>> channels_to_reduce_mem; { + MonotonicStopWatch timer; + timer.start(); std::unique_lock<std::mutex> l(_lock); while (_should_wait_flush) { - LOG(INFO) << "Reached the load hard limit " << _load_hard_mem_limit - << ", waiting for flush"; _wait_flush_cond.wait(l); } + LOG(INFO) << "Reached the load hard limit " << _load_hard_mem_limit + << ", waited for flush, time_ns:" << timer.elapsed_time(); + bool hard_limit_reached = _mem_tracker->consumption() >= _load_hard_mem_limit || MemInfo::proc_mem_no_allocator_cache() >= process_mem_limit; // Some other thread is flushing data, and not reached hard limit now, --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
