branch-2.1: [fix](profile) only printed for non-sink nodes in the mer…

…ge profile. #44040 (#44252) Cherry-picked from #44040 Co-authored-by: Mryange <[email protected]>
apache · Nov 19, 2024 · 1b1e2e8 · 1b1e2e8
1 parent 2eb66c2
commit 1b1e2e8
Showing 1 changed file with 11 additions and 2 deletions.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/common/util/RuntimeProfile.java b/fe/fe-core/src/main/java/org/apache/doris/common/util/RuntimeProfile.java
@@ -654,8 +654,17 @@ public void addChildWithCheck(RuntimeProfile child, Map<Integer, String> planNod
         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) {