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