From f968d965452eb53b315e4fa32c3b1cd933ed42ec Mon Sep 17 00:00:00 2001 From: Gabriel Date: Fri, 8 Mar 2024 10:13:36 +0800 Subject: [PATCH] [profile](pipelineX) Add lost metrics (#31964) --- be/src/pipeline/exec/partition_sort_sink_operator.cpp | 2 ++ 1 file changed, 2 insertions(+) diff --git a/be/src/pipeline/exec/partition_sort_sink_operator.cpp b/be/src/pipeline/exec/partition_sort_sink_operator.cpp index 7c2bf51ad5..2481302fd4 100644 --- a/be/src/pipeline/exec/partition_sort_sink_operator.cpp +++ b/be/src/pipeline/exec/partition_sort_sink_operator.cpp @@ -30,6 +30,7 @@ OperatorPtr PartitionSortSinkOperatorBuilder::build_operator() { Status PartitionSortSinkLocalState::init(RuntimeState* state, LocalSinkStateInfo& info) { RETURN_IF_ERROR(PipelineXSinkLocalState::init(state, info)); SCOPED_TIMER(exec_time_counter()); + SCOPED_TIMER(_open_timer); auto& p = _parent->cast(); RETURN_IF_ERROR(p._vsort_exec_exprs.clone(state, _vsort_exec_exprs)); _partition_expr_ctxs.resize(p._partition_expr_ctxs.size()); @@ -100,6 +101,7 @@ Status PartitionSortSinkOperatorX::sink(RuntimeState* state, vectorized::Block* auto& local_state = get_local_state(state); auto current_rows = input_block->rows(); SCOPED_TIMER(local_state.exec_time_counter()); + COUNTER_UPDATE(local_state.rows_input_counter(), (int64_t)input_block->rows()); if (current_rows > 0) { local_state.child_input_rows = local_state.child_input_rows + current_rows; if (UNLIKELY(_partition_exprs_num == 0)) {