This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new 938ca71604b [fix](profile) do not merge fragment_level profile (#45200)
938ca71604b is described below
commit 938ca71604ba736cdd269e419a1dfe76c1579b54
Author: Mryange <yanxuech...@selectdb.com>
AuthorDate: Tue Dec 10 09:58:21 2024 +0800
[fix](profile) do not merge fragment_level profile (#45200)
---
.../main/java/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 054996d6fb1..29ef587c939 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 class ExecutionProfile {
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);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
