From 938ca71604ba736cdd269e419a1dfe76c1579b54 Mon Sep 17 00:00:00 2001 From: Mryange Date: Tue, 10 Dec 2024 09:58:21 +0800 Subject: [PATCH] [fix](profile) do not merge fragment_level profile (#45200) --- .../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); }