[fix](profile) do not merge fragment_level profile (#45200)

apache · Dec 10, 2024 · 938ca71 · 938ca71
1 parent da3c56d
commit 938ca71
Showing 1 changed file with 5 additions and 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
@@ -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);
                 }