This is an automated email from the ASF dual-hosted git repository. yiguolei pushed a commit to branch 2.1-tmp in repository https://gitbox.apache.org/repos/asf/doris.git
commit 1d0908e80d1a785c2001b187cfe24945eebc3fb7 Author: Mryange <[email protected]> AuthorDate: Mon Apr 1 11:57:32 2024 +0800 [feature](profile) make WaitForLocalExchangeBuffer timer merge (#32946) make WaitForLocalExchangeBuffer timer merge --- be/src/pipeline/exec/exchange_sink_operator.cpp | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/be/src/pipeline/exec/exchange_sink_operator.cpp b/be/src/pipeline/exec/exchange_sink_operator.cpp index 9c3d68c472f..bc55bc8f805 100644 --- a/be/src/pipeline/exec/exchange_sink_operator.cpp +++ b/be/src/pipeline/exec/exchange_sink_operator.cpp @@ -197,8 +197,9 @@ Status ExchangeSinkLocalState::init(RuntimeState* state, LocalSinkStateInfo& inf if (channel->is_local()) { _local_channels_dependency[dep_id] = channel->get_local_channel_dependency(); DCHECK(_local_channels_dependency[dep_id] != nullptr); - _wait_channel_timer[dep_id] = ADD_CHILD_TIMER( - _profile, fmt::format("WaitForLocalExchangeBuffer{}", dep_id), timer_name); + _wait_channel_timer[dep_id] = ADD_CHILD_TIMER_WITH_LEVEL( + _profile, fmt::format("WaitForLocalExchangeBuffer{}", dep_id), timer_name, + 1); dep_id++; } } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
