database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

branch-2.1: [fix](profile) only printed for non-sink nodes in the merge profile. #44040 (#44252)

Browse Source 
Cherry-picked from #44040

Co-authored-by: Mryange <yanxuecheng@selectdb.com>
This commit is contained in:
github-actions[bot]
2024-11-19 17:34:38 +08:00
committed by GitHub
parent 2eb66c2609
commit 1b1e2e8a29
1 changed files with 11 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
fe/fe-core/src/main/java/org/apache/doris/common/util/RuntimeProfile.java
View File

@ -654,8 +654,17 @@ public class RuntimeProfile {
if (planNodeMap == null || !planNodeMap.containsKey(child.nodeId())) {
return;
}
child.addPlanNodeInfos(planNodeMap.get(child.nodeId()));
planNodeMap.remove(child.nodeId());
/*
* The check for SINK_OPERATOR is performed because SINK_OPERATOR does not have
* a corresponding plan node ID.
* Currently, the plan node info is only printed for non-sink nodes in the merge
* profile.
*/
if (name.contains("_SINK_OPERATOR")) {
child.addPlanNodeInfos(planNodeMap.get(child.nodeId()));
planNodeMap.remove(child.nodeId());
}
}
public void addPlanNodeInfos(String infos) {