From 8aa587d4da8042c0f370b22803190a333c3b3e02 Mon Sep 17 00:00:00 2001 From: zhangstar333 Date: Thu, 28 Nov 2024 19:51:26 +0800 Subject: [PATCH] update --- be/src/pipeline/exec/nested_loop_join_build_operator.cpp | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/be/src/pipeline/exec/nested_loop_join_build_operator.cpp b/be/src/pipeline/exec/nested_loop_join_build_operator.cpp index c4de9c9f799374..9192d67dd316b2 100644 --- a/be/src/pipeline/exec/nested_loop_join_build_operator.cpp +++ b/be/src/pipeline/exec/nested_loop_join_build_operator.cpp @@ -147,12 +147,12 @@ Status NestedLoopJoinBuildSinkOperatorX::sink(doris::RuntimeState* state, vector auto rows = block->rows(); if (rows != 0) { - COUNTER_UPDATE(local_state.rows_input_counter(), (int64_t)rows); if (_match_all_build || _is_right_semi_anti) { local_state._shared_state->build_side_visited_flags.emplace_back( vectorized::ColumnUInt8::create(rows, 0)); } if (local_state._should_collected_blocks) { + COUNTER_UPDATE(local_state.rows_input_counter(), (int64_t)rows); auto mem_usage = block->allocated_bytes(); local_state._build_rows += rows; local_state._total_mem_usage += mem_usage;