This is an automated email from the ASF dual-hosted git repository.
zhangstar333 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 304443d1d8d [bug](analytic) fix duplicate add _num_rows_returned issue
(#47366)
304443d1d8d is described below
commit 304443d1d8d810dbd52df60fe1b5b083e43adc46
Author: zhangstar333 <zhangs...@selectdb.com>
AuthorDate: Sun Jan 26 10:52:58 2025 +0800
[bug](analytic) fix duplicate add _num_rows_returned issue (#47366)
### What problem does this PR solve?
Problem Summary:
the _num_rows_returned have been add twice
introduced by https://github.com/apache/doris/pull/46181,
and only in master.
---
be/src/pipeline/exec/analytic_source_operator.cpp | 1 -
.../query_p0/sql_functions/window_functions/test_column_boundary.groovy | 2 +-
2 files changed, 1 insertion(+), 2 deletions(-)
diff --git a/be/src/pipeline/exec/analytic_source_operator.cpp
b/be/src/pipeline/exec/analytic_source_operator.cpp
index ce6f0d1d107..b9635ce6eb4 100644
--- a/be/src/pipeline/exec/analytic_source_operator.cpp
+++ b/be/src/pipeline/exec/analytic_source_operator.cpp
@@ -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();
diff --git
a/regression-test/suites/query_p0/sql_functions/window_functions/test_column_boundary.groovy
b/regression-test/suites/query_p0/sql_functions/window_functions/test_column_boundary.groovy
index bfdf501d904..761dbe3a985 100644
---
a/regression-test/suites/query_p0/sql_functions/window_functions/test_column_boundary.groovy
+++
b/regression-test/suites/query_p0/sql_functions/window_functions/test_column_boundary.groovy
@@ -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
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
