From 1d0908e80d1a785c2001b187cfe24945eebc3fb7 Mon Sep 17 00:00:00 2001 From: Mryange <59914473+Mryange@users.noreply.github.com> Date: Mon, 1 Apr 2024 11:57:32 +0800 Subject: [PATCH] [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 9c3d68c472..bc55bc8f80 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++; } }