This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new 22da62a6d5f [fix](shuffle) compensate num rows filtered in
ExchangeNode (#34605) (#34623)
22da62a6d5f is described below
commit 22da62a6d5f89e48de61f37ae09c86b83c852ad7
Author: Kaijie Chen <c...@apache.org>
AuthorDate: Fri May 10 09:27:31 2024 +0800
[fix](shuffle) compensate num rows filtered in ExchangeNode (#34605)
(#34623)
---
be/src/pipeline/exec/exchange_sink_operator.cpp | 3 +++
1 file changed, 3 insertions(+)
diff --git a/be/src/pipeline/exec/exchange_sink_operator.cpp
b/be/src/pipeline/exec/exchange_sink_operator.cpp
index 84381c6a8af..2e0972ca5ee 100644
--- a/be/src/pipeline/exec/exchange_sink_operator.cpp
+++ b/be/src/pipeline/exec/exchange_sink_operator.cpp
@@ -691,6 +691,9 @@ Status ExchangeSinkLocalState::close(RuntimeState* state,
Status exec_status) {
_tablet_finder->num_filtered_rows());
_state->update_num_rows_load_unselected(
_tablet_finder->num_immutable_partition_filtered_rows());
+ // sink won't see those filtered rows, we should compensate here
+ _state->set_num_rows_load_total(_state->num_rows_load_filtered() +
+ _state->num_rows_load_unselected());
}
SCOPED_TIMER(exec_time_counter());
SCOPED_TIMER(_close_timer);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
