924060929 commented on code in PR #65129:
URL: https://github.com/apache/doris/pull/65129#discussion_r3578379926
##########
fe/fe-core/src/main/java/org/apache/doris/planner/SetOperationNode.java:
##########
@@ -223,7 +223,15 @@ public Pair<PlanNode, LocalExchangeType>
enforceAndDeriveLocalExchange(PlanTrans
: LocalExchangeType.NOOP;
} else {
// Intersect / Except
- if (AddLocalExchange.isColocated(this)) {
+ if (AddLocalExchange.isColocated(this) || isBucketShuffle()) {
Review Comment:
Added a targeted `IntersectNode` bucket-shuffle case to
`testSetOperationAndAssertNumRowsNode`: `setColocate(false)` +
`setDistributionMode(BUCKET_SHUFFLE)` so `isColocated()` is false and the
branch is reached through `isBucketShuffle()` alone, NOOP children, asserting
`BUCKET_HASH_SHUFFLE` output and both children re-aligned with a
`BUCKET_HASH_SHUFFLE` local exchange. Dropping the `|| isBucketShuffle()`
branch now fails this test — it would take the partitioned GLOBAL-hash leg
instead.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
