From 02d9e3f30bbef4d0e2c8af53316ea6743c4d194d Mon Sep 17 00:00:00 2001 From: Mryange Date: Mon, 9 Dec 2024 17:13:52 +0800 Subject: [PATCH] upd --- .../org/apache/doris/common/profile/ExecutionProfile.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/fe/fe-core/src/main/java/org/apache/doris/common/profile/ExecutionProfile.java b/fe/fe-core/src/main/java/org/apache/doris/common/profile/ExecutionProfile.java index 054996d6fb1a57..29ef587c939472 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/common/profile/ExecutionProfile.java +++ b/fe/fe-core/src/main/java/org/apache/doris/common/profile/ExecutionProfile.java @@ -265,7 +265,11 @@ public void updateProfile(TReportExecStatusParams params) { String name = param.isSetIsFragmentLevel() && param.is_fragment_level ? "Fragment Level Profile: " + suffix : "Pipeline :" + pipelineIdx + " " + suffix; RuntimeProfile profile = new RuntimeProfile(name); - taskProfile.add(profile); + // The taskprofile is used to save the profile of the pipeline, without + // considering the FragmentLevel. + if (!(param.isSetIsFragmentLevel() && param.is_fragment_level)) { + taskProfile.add(profile); + } if (param.isSetProfile()) { profile.update(param.profile); }