This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a change to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
from c6df7c21a3c [branch-2.1](hive) support hive write text table (#38549)
(#40063)
add 841565a40d1 [fix](local shuffle) Fix hash shuffle local exchanger
(#40101)
No new revisions were added by this update.
Summary of changes:
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 | 34 ++++++++++
.../local_exchange/local_exchange_sink_operator.h | 34 +---------
.../pipeline_x/local_exchange/local_exchanger.cpp | 29 +--------
.../pipeline_x/pipeline_x_fragment_context.cpp | 72 +++++++++++++++++-----
.../pipeline_x/pipeline_x_fragment_context.h | 5 +-
.../nereids_p0/join/test_join_local_shuffle.groovy | 6 +-
18 files changed, 136 insertions(+), 84 deletions(-)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
