diff --git a/fe/fe-core/src/main/java/org/apache/doris/common/util/ProfileManager.java b/fe/fe-core/src/main/java/org/apache/doris/common/util/ProfileManager.java index 3922c496c7..6429b0854e 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/common/util/ProfileManager.java +++ b/fe/fe-core/src/main/java/org/apache/doris/common/util/ProfileManager.java @@ -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 { diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java b/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java index 065776ce6a..f3c5e9d2c9 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java +++ b/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java @@ -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; }