database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[enhancement](profile) add session variable parallel_fragment_exec_instance_num to profile (#15457)

Browse Source
This commit is contained in:
luozenglin
2022-12-29 14:46:07 +08:00
committed by GitHub
parent 657f3e6318
commit d95be84629
2 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
fe/fe-core/src/main/java/org/apache/doris/common/util/ProfileManager.java
View File

@ -74,6 +74,8 @@ public class ProfileManager {
public static final String INSTANCES_NUM_PER_BE = "Instances Num Per BE";
public static final String PARALLEL_FRAGMENT_EXEC_INSTANCE = "Parallel Fragment Exec Instance Num";
public static final String TRACE_ID = "Trace ID";
public enum ProfileType {

2
fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java
View File

@ -314,6 +314,8 @@ public class StmtExecutor implements ProfileWriter {
infos.put(ProfileManager.TOTAL_INSTANCES_NUM,
String.valueOf(beToInstancesNum.values().stream().reduce(0, Integer::sum)));
infos.put(ProfileManager.INSTANCES_NUM_PER_BE, beToInstancesNum.toString());
infos.put(ProfileManager.PARALLEL_FRAGMENT_EXEC_INSTANCE,
String.valueOf(context.sessionVariable.parallelExecInstanceNum));
return infos;
}