[doris] 03/06: [improvement](load) log time consumed by waiting flush (#19226)

[mo...@apache.org]

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 <98...@users.noreply.github.com>
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: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org