This is an automated email from the ASF dual-hosted git repository.
mrhhsg pushed a commit to branch spill_repartition
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/spill_repartition by this push:
new 2c23a07f5ac disbale distinct streaming agg when spill enabled
2c23a07f5ac is described below
commit 2c23a07f5ac5afce8588b9a7a4ff9938906d058e
Author: Hu Shenggang <[email protected]>
AuthorDate: Sat Feb 28 17:27:26 2026 +0800
disbale distinct streaming agg when spill enabled
---
be/src/pipeline/pipeline_fragment_context.cpp | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git a/be/src/pipeline/pipeline_fragment_context.cpp
b/be/src/pipeline/pipeline_fragment_context.cpp
index 848647c89ad..4ce764df25f 100644
--- a/be/src/pipeline/pipeline_fragment_context.cpp
+++ b/be/src/pipeline/pipeline_fragment_context.cpp
@@ -1322,8 +1322,9 @@ Status
PipelineFragmentContext::_create_operator(ObjectPool* pool, const TPlanNo
const bool is_streaming_agg =
tnode.agg_node.__isset.use_streaming_preaggregation &&
tnode.agg_node.use_streaming_preaggregation &&
!tnode.agg_node.grouping_exprs.empty();
+ // TODO: distinct streaming agg does not support spill.
const bool can_use_distinct_streaming_agg =
- tnode.agg_node.aggregate_functions.empty() &&
+ (!enable_spill || is_streaming_agg) &&
tnode.agg_node.aggregate_functions.empty() &&
!tnode.agg_node.__isset.agg_sort_info_by_group_key &&
_params.query_options.__isset.enable_distinct_streaming_aggregation &&
_params.query_options.enable_distinct_streaming_aggregation;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
