morrySnow commented on code in PR #30901:
URL: https://github.com/apache/doris/pull/30901#discussion_r1479402476
##########
fe/fe-core/src/main/java/org/apache/doris/nereids/processor/post/RuntimeFilterGenerator.java:
##########
@@ -159,17 +159,23 @@ public Plan processRoot(Plan plan, CascadesContext ctx) {
// since the srcExpr are the same, all buildNodes
of rfToPushDown are in the same tree path
// the longest ancestors means its corresponding
rf build node is the most right deep one.
RuntimeFilter rightDeep = rfsToPushDown.get(0);
+ List<RuntimeFilter> rightDeepAccompanies =
Lists.newArrayList();
List<Plan> rightDeepAncestors =
rfsToPushDown.get(0).getBuilderNode().getAncestors();
int rightDeepAncestorsSize =
rightDeepAncestors.size();
RuntimeFilter leftTop = rfsToPushDown.get(0);
int leftTopAncestorsSize = rightDeepAncestorsSize;
for (RuntimeFilter rf : rfsToPushDown) {
List<Plan> ancestors =
rf.getBuilderNode().getAncestors();
int currentAncestorsSize = ancestors.size();
- if (currentAncestorsSize >
rightDeepAncestorsSize) {
- rightDeep = rf;
- rightDeepAncestorsSize =
currentAncestorsSize;
- rightDeepAncestors = ancestors;
+ if (currentAncestorsSize >=
rightDeepAncestorsSize) {
+ if (currentAncestorsSize ==
rightDeepAncestorsSize) {
+ rightDeepAccompanies.add(rf);
+ } else {
+ rightDeepAncestorsSize =
currentAncestorsSize;
+ rightDeepAncestors = ancestors;
+ rightDeep = rf;
Review Comment:
rightDeep is not use anymore
--
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: commits-unsubscr...@doris.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
