924060929 commented on code in PR #67177:
URL: https://github.com/apache/doris/pull/67177#discussion_r3878388799
##########
fe/fe-core/src/main/java/org/apache/doris/nereids/trees/plans/distribute/DistributePlanner.java:
##########
@@ -212,12 +222,14 @@ private void linkPipelinePlan(
PipelineDistributedPlan receiverPlan,
PipelineDistributedPlan senderPlan,
ExchangeNode linkNode,
- boolean enableShareHashTableForBroadcastJoin) {
+ boolean enableShareHashTableForBroadcastJoin,
+ boolean enableLocalShufflePlanner) {
Review Comment:
Fixed in 593c5005b8a. The v13 fallback now freezes the effective query-level
local-shuffle-planner decision into every remote Exchange before receiver
assignment. Both receiver destination filtering and Exchange Thrift
serialization read that frozen value, while the legacy planner keeps its
original session-based fallback. This aligns new-FE/old-BE planning: v13
targets only the first receiver instance per worker and serializes
`is_serial_operator=true`, matching the old BE native planner source
cardinality. The v13 unit test pins a bucket-shuffle Exchange with exactly
three pooled receiver instances, verifies every bucket destination is the first
instance on its worker, and checks the same Exchange Thrift node is serial. The
focused FE suite passes 72/72, Checkstyle has zero violations, and `./build.sh
--fe -j6` passes.
--
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]
