Skip to content

Commit

Permalink
[bug](analytic) fix duplicate add _num_rows_returned issue (#47366)
Browse files Browse the repository at this point in the history
### What problem does this PR solve?
Problem Summary:
the _num_rows_returned have been add twice
introduced by #46181,
and only in master.
  • Loading branch information
zhangstar333 authored Jan 26, 2025
1 parent ca506fa commit 304443d
Show file tree
Hide file tree
Showing 2 changed files with 1 addition and 2 deletions.
1 change: 0 additions & 1 deletion be/src/pipeline/exec/analytic_source_operator.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -81,7 +81,6 @@ Status AnalyticSourceOperatorX::get_block(RuntimeState* state, vectorized::Block
local_state.reached_limit(output_block, eos);
if (!output_block->empty()) {
auto return_rows = output_block->rows();
local_state._num_rows_returned += return_rows;
COUNTER_UPDATE(local_state._filtered_rows_counter, output_rows - return_rows);
}
return Status::OK();
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -20,7 +20,7 @@ suite("test_column_boundary") {
sql """
CREATE TABLE IF NOT EXISTS test_column_boundary (
u_id int NULL COMMENT "",
u_city varchar(20) NULL COMMENT ""
u_city varchar(40) NULL COMMENT ""
) ENGINE=OLAP
DUPLICATE KEY(`u_id`, `u_city`)
DISTRIBUTED BY HASH(`u_id`, `u_city`) BUCKETS 1
Expand Down

0 comments on commit 304443d

Please sign in to comment.