32

Author: 宋光璠

fe/fe-core/src/main/java/org/apache/doris/common/profile/SummaryProfile.java

@@ -284,10 +284,10 @@ public class SummaryProfile {
     private long nereidsLockTableFinishTime = -1;
 
     @SerializedName(value = "memoryLimit")
-    private long memoryLimit = 0;
+    private int memoryLimit = 0;
 
     @SerializedName(value = "cpuShare")
-    private long cpuShare = -1;
+    private int cpuShare = 0;
 
     @SerializedName(value = "enableMemoryOvercommit")
     private long enableMemoryOvercommit = 0;
@@ -585,6 +585,8 @@ private void updateExecutionSummaryProfile() {
             RuntimeProfile.printCounter(queryWriteResultConsumeTime, TUnit.TIME_MS));
         executionSummaryProfile.addInfoString(CPU_SHARE,
             RuntimeProfile.printCounter(cpuShare, TUnit.DOUBLE_VALUE));
+        executionSummaryProfile.addInfoString(MEMORY_LIMIT,
+            RuntimeProfile.printCounter(memoryLimit, TUnit.DOUBLE_VALUE));
         setTransactionSummary();
 
         if (Config.isCloudMode()) {
@@ -658,10 +660,14 @@ public void setNereidsLockTableFinishTime(long lockTableFinishTime) {
         this.nereidsLockTableFinishTime = lockTableFinishTime;
     }
 
-    public void setCpuShare(long cpuShare) {
+    public void setCpuShare(int cpuShare) {
          this.cpuShare = cpuShare;
     }
 
+    public void setMemoryLimit(int memoryLimit) {
+        this.memoryLimit = memoryLimit;
+    }
+
     public void setNereidsCollectTablePartitionFinishTime(long collectTablePartitionFinishTime) {
         this.nereidsCollectTablePartitionFinishTime = collectTablePartitionFinishTime;
     }

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

@@ -350,7 +350,7 @@ private Map<String, String> getSummaryInfo(boolean isFinished) {
             if (!list.isEmpty()) {
                 WorkloadGroup wg = list.get(0);
                 getSummaryProfile().setCpuShare(wg.getMaxCpuPercent());
-                builder.memoryLimit(String.valueOf(wg.getMaxMemoryPercent()));
+                getSummaryProfile().setMemoryLimit(wg.getMaxMemoryPercent());
             }
         } catch (UserException e) {
             throw new RuntimeException(e);