This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a change to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/doris.git
from 2d9ef61f272 [fix](recycler) Implement missing delete_prefix() of hdfs
accessor (#40215)
new c97772e5a9f [fix](followup) Fix wrong partition num (#39916)
new 9b54e282acf [refactor](local exchange) Refactor logics (#39771)
new af1b6db6052 [Improvement](local exchange) optimize broadcast local
exchanger (#39402)
new 24fce53b344 [fix](local shuffle) Not channel_id causes a local merge
infinite loop. (#39725)
new d117ed7191f [fix](local shuffle) Fix hash shuffle local exchanger
(#40036)
The 5 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
be/src/pipeline/dependency.h | 4 +-
be/src/pipeline/exec/aggregation_sink_operator.h | 3 +-
be/src/pipeline/exec/analytic_sink_operator.h | 5 +-
.../exec/distinct_streaming_aggregation_operator.h | 5 +-
be/src/pipeline/exec/hashjoin_build_sink.h | 3 +
be/src/pipeline/exec/hashjoin_probe_operator.h | 3 +
be/src/pipeline/exec/operator.h | 6 +
.../exec/partitioned_aggregation_sink_operator.h | 3 +
.../exec/partitioned_hash_join_probe_operator.h | 3 +
.../exec/partitioned_hash_join_sink_operator.h | 3 +
be/src/pipeline/exec/set_probe_sink_operator.h | 2 +
be/src/pipeline/exec/set_sink_operator.h | 1 +
be/src/pipeline/exec/sort_sink_operator.h | 3 +-
.../local_exchange_sink_operator.cpp | 16 +--
.../local_exchange/local_exchange_sink_operator.h | 2 +-
.../local_exchange_source_operator.cpp | 21 ++-
.../local_exchange_source_operator.h | 2 +
be/src/pipeline/local_exchange/local_exchanger.cpp | 156 ++++++++++++---------
be/src/pipeline/local_exchange/local_exchanger.h | 41 +++---
be/src/pipeline/pipeline_fragment_context.cpp | 63 +++++++--
be/src/pipeline/pipeline_fragment_context.h | 5 +-
.../nereids_p0/join/test_join_local_shuffle.groovy | 6 +-
22 files changed, 238 insertions(+), 118 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
