This is an automated email from the ASF dual-hosted git repository.
yiguolei 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 9fcbecaf4fb [bugfix](spill) use batch_size session var to limit spill
sort output block batch row count (#50158)
9fcbecaf4fb is described below
commit 9fcbecaf4fb7a72d4b942e889b7b7bc865b36c7b
Author: TengJianPing <[email protected]>
AuthorDate: Sat Apr 19 17:13:47 2025 +0800
[bugfix](spill) use batch_size session var to limit spill sort output block
batch row count (#50158)
---
be/src/pipeline/exec/spill_sort_source_operator.cpp | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/be/src/pipeline/exec/spill_sort_source_operator.cpp
b/be/src/pipeline/exec/spill_sort_source_operator.cpp
index ae12f139069..a212c8772fa 100644
--- a/be/src/pipeline/exec/spill_sort_source_operator.cpp
+++ b/be/src/pipeline/exec/spill_sort_source_operator.cpp
@@ -180,7 +180,7 @@ Status SpillSortLocalState::_create_intermediate_merger(
int num_blocks, const vectorized::SortDescription& sort_description) {
std::vector<vectorized::BlockSupplier> child_block_suppliers;
_merger = std::make_unique<vectorized::VSortedRunMerger>(
- sort_description, _shared_state->spill_block_batch_row_count,
+ sort_description, _runtime_state->batch_size(),
Base::_shared_state->in_mem_shared_state->sorter->limit(),
Base::_shared_state->in_mem_shared_state->sorter->offset(),
profile());
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
