[pipelineX](localshuffle) Adjust local exchange strategy for distinct…

… streaming agg (#32767) Adjust local exchange strategy for distinct streaming agg
apache · Mar 25, 2024 · e0e7e5f · e0e7e5f
1 parent e98b4b3
commit e0e7e5f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/be/src/pipeline/exec/distinct_streaming_aggregation_operator.h b/be/src/pipeline/exec/distinct_streaming_aggregation_operator.h
@@ -97,7 +97,7 @@ class DistinctStreamingAggOperatorX final
     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);