From d95be846295c6fd0acdbad1cd8bdb127aabd5ad0 Mon Sep 17 00:00:00 2001
From: luozenglin <37725793+luozenglin@users.noreply.github.com>
Date: Thu, 29 Dec 2022 14:46:07 +0800
Subject: [PATCH] [enhancement](profile) add session variable
 parallel_fragment_exec_instance_num to profile (#15457)

---
 .../main/java/org/apache/doris/common/util/ProfileManager.java  | 2 ++
 fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java  | 2 ++
 2 files changed, 4 insertions(+)

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;
     }