This is an automated email from the ASF dual-hosted git repository.
huajianlan pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
from cdda689c03a [Fix](p0) Remove dependency on pre-existing doris_test
database in binary digest test (#58291)
add df18c506ffd [opt](nereids) support random local shuffle for union
(#58042)
No new revisions were added by this update.
Summary of changes:
be/src/pipeline/exec/exchange_sink_operator.cpp | 23 +++-
be/src/pipeline/exec/exchange_sink_operator.h | 1 +
.../glue/translator/PhysicalPlanTranslator.java | 46 +++++++
.../worker/job/UnassignedJobBuilder.java | 6 +-
.../worker/job/UnassignedLocalShuffleUnionJob.java | 99 +++++++++++++++
.../org/apache/doris/planner/DataPartition.java | 3 +-
.../org/apache/doris/planner/ExchangeNode.java | 13 +-
.../java/org/apache/doris/planner/UnionNode.java | 10 ++
.../nereids/distribute/LocalShuffleUnionTest.java | 141 +++++++++++++++++++++
gensrc/thrift/Partitions.thrift | 3 +
10 files changed, 339 insertions(+), 6 deletions(-)
create mode 100644
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/distribute/worker/job/UnassignedLocalShuffleUnionJob.java
create mode 100644
fe/fe-core/src/test/java/org/apache/doris/nereids/distribute/LocalShuffleUnionTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
