englefly commented on code in PR #67433:
URL: https://github.com/apache/doris/pull/67433#discussion_r4410081280
##########
fe/fe-core/src/main/java/org/apache/doris/planner/PlanFragment.java:
##########
@@ -206,6 +206,19 @@ private Supplier<Boolean> buildHasBucketShuffleNode() {
return true;
}
}
+ // A fused group join is a PlanNode in its own right, it does not
extend HashJoinNode, so
+ // the two loops above cannot see the bucket shuffle of a fused
INNER join. Missing it
+ // made the scan job of the bucket side an
UnassignedScanSingleOlapTableJob while the
+ // exchange into the join still claimed
BUCKET_SHFFULE_HASH_PARTITIONED, and
+ // DistributePlanner.getDestinationsByBuckets then failed to cast
that job to
+ // UnassignedScanBucketOlapTableJob.
+ List<GroupJoinNode> groupJoinNodes
Review Comment:
legacy Coordinator 在4.2后默认不使用. 改进方式: 如果session var强制使用legacy, 就不使用groupJoin
--
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]
