database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[feature](profile) make WaitForLocalExchangeBuffer timer merge (#32946)

Browse Source 
make WaitForLocalExchangeBuffer timer merge
This commit is contained in:
Mryange
2024-04-01 11:57:32 +08:00
committed by yiguolei
parent e4993a19e5
commit 1d0908e80d
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
be/src/pipeline/exec/exchange_sink_operator.cpp
View File

@ -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++;
}
}