This is an automated email from the ASF dual-hosted git repository. yiguolei pushed a commit to branch branch-2.1 in repository https://gitbox.apache.org/repos/asf/doris.git
commit 41b9556a257a53a2ec9b218df0c70d6468dd6154 Author: Gabriel <[email protected]> AuthorDate: Mon Mar 25 19:19:03 2024 +0800 [pipelineX](localshuffle) Adjust local exchange strategy for distinct streaming agg (#32767) Adjust local exchange strategy for distinct streaming agg --- be/src/pipeline/exec/distinct_streaming_aggregation_operator.h | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/be/src/pipeline/exec/distinct_streaming_aggregation_operator.h b/be/src/pipeline/exec/distinct_streaming_aggregation_operator.h index 372e3a5a0ca..4c15194362e 100644 --- a/be/src/pipeline/exec/distinct_streaming_aggregation_operator.h +++ b/be/src/pipeline/exec/distinct_streaming_aggregation_operator.h @@ -97,7 +97,7 @@ public: bool need_more_input_data(RuntimeState* state) const override; DataDistribution required_data_distribution() const override { - if (_needs_finalize || !_probe_expr_ctxs.empty()) { + if (_needs_finalize || (!_probe_expr_ctxs.empty() && !_is_streaming_preagg)) { return _is_colocate ? DataDistribution(ExchangeType::BUCKET_HASH_SHUFFLE, _partition_exprs) : DataDistribution(ExchangeType::HASH_SHUFFLE, _partition_exprs); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
