This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new 8902df51ced [chore](profile) rm useless code of profile (#36915)
8902df51ced is described below
commit 8902df51ced892e2d08ddfc355e18242320a0339
Author: zhiqiang <[email protected]>
AuthorDate: Fri Jun 28 18:44:06 2024 +0800
[chore](profile) rm useless code of profile (#36915)
---
.../doris/common/profile/ExecutionProfile.java | 23 ----------------------
1 file changed, 23 deletions(-)
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 3c683fced9d..ebe41c1146f 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
@@ -76,8 +76,6 @@ public class ExecutionProfile {
private Map<Integer, RuntimeProfile> fragmentProfiles;
// Profile for load channels. Only for load job.
private RuntimeProfile loadChannelProfile;
- // FragmentId -> InstanceId -> RuntimeProfile
- private Map<PlanFragmentId, Map<TUniqueId, RuntimeProfile>>
fragmentInstancesProfiles;
// use to merge profile from multi be
private Map<Integer, Map<TNetworkAddress, List<RuntimeProfile>>>
multiBeProfile = null;
@@ -85,8 +83,6 @@ public class ExecutionProfile {
// Not serialize this property, it is only used to get profile id.
private SummaryProfile summaryProfile;
- // BE only has instance id, does not have fragmentid, so should use this
map to find fragmentid.
- private Map<TUniqueId, PlanFragmentId> instanceIdToFragmentId;
private Map<Integer, Integer> fragmentIdBeNum;
private Map<Integer, Integer> seqNoToFragmentId;
@@ -112,8 +108,6 @@ public class ExecutionProfile {
}
loadChannelProfile = new RuntimeProfile("LoadChannels");
root.addChild(loadChannelProfile);
- fragmentInstancesProfiles = Maps.newHashMap();
- instanceIdToFragmentId = Maps.newHashMap();
}
private List<List<RuntimeProfile>> getMultiBeProfile(int fragmentId) {
@@ -299,23 +293,6 @@ public class ExecutionProfile {
multiBeProfile.get(params.fragment_id).put(backend.getHeartbeatAddress(),
taskProfile);
}
- // MultiInstances may update the profile concurrently
- public synchronized void addInstanceProfile(PlanFragmentId fragmentId,
TUniqueId instanceId,
- RuntimeProfile instanceProfile) {
- Map<TUniqueId, RuntimeProfile> instanceProfiles =
fragmentInstancesProfiles.get(fragmentId);
- if (instanceProfiles == null) {
- instanceProfiles = Maps.newHashMap();
- fragmentInstancesProfiles.put(fragmentId, instanceProfiles);
- }
- RuntimeProfile existingInstanceProfile =
instanceProfiles.get(instanceId);
- if (existingInstanceProfile == null) {
- instanceProfiles.put(instanceId, instanceProfile);
- instanceIdToFragmentId.put(instanceId, fragmentId);
- fragmentProfiles.get(fragmentId.asInt()).addChild(instanceProfile);
- return;
- }
- }
-
public synchronized void addFragmentBackend(PlanFragmentId fragmentId,
Long backendId) {
fragmentIdBeNum.put(fragmentId.asInt(),
fragmentIdBeNum.get(fragmentId.asInt()) + 1);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
