This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch branch-3.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-3.0 by this push:
new 3db632d7644 branch-3.0: [fix](profile) only printed for non-sink
nodes in the merge profile. #44040 (#44251)
3db632d7644 is described below
commit 3db632d7644271a5acfd241f7dc71b93a9cf674e
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Tue Dec 3 21:52:40 2024 +0800
branch-3.0: [fix](profile) only printed for non-sink nodes in the merge
profile. #44040 (#44251)
Cherry-picked from #44040
Co-authored-by: Mryange <[email protected]>
---
.../java/org/apache/doris/common/util/RuntimeProfile.java | 13 +++++++++++--
1 file changed, 11 insertions(+), 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
index 3ffc303a6db..19082959034 100644
--- 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
@@ -682,8 +682,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) {
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
