You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by mo...@apache.org on 2023/06/29 10:18:43 UTC
[doris] 01/01: [opt](profile) add whether use Nereids info in Profile
This is an automated email from the ASF dual-hosted git repository.
morrysnow pushed a commit to branch add_is_nereids_in_profile
in repository https://gitbox.apache.org/repos/asf/doris.git
commit 93d108cf33059d51d6c1ccbb53f2b14acea15842
Author: morrySnow <mo...@126.com>
AuthorDate: Thu Jun 29 18:18:24 2023 +0800
[opt](profile) add whether use Nereids info in Profile
---
.../main/java/org/apache/doris/common/profile/SummaryProfile.java | 8 +++++++-
fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java | 1 +
2 files changed, 8 insertions(+), 1 deletion(-)
diff --git a/fe/fe-core/src/main/java/org/apache/doris/common/profile/SummaryProfile.java b/fe/fe-core/src/main/java/org/apache/doris/common/profile/SummaryProfile.java
index e3e2586307..5cb8b735a6 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/common/profile/SummaryProfile.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/common/profile/SummaryProfile.java
@@ -42,6 +42,7 @@ public class SummaryProfile {
public static final String DEFAULT_DB = "Default Db";
public static final String SQL_STATEMENT = "Sql Statement";
public static final String IS_CACHED = "Is Cached";
+ public static final String IS_NEREIDS = "Is Nereids";
public static final String TOTAL_INSTANCES_NUM = "Total Instances Num";
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";
@@ -56,7 +57,7 @@ public class SummaryProfile {
public static final String WAIT_FETCH_RESULT_TIME = "Wait and Fetch Result Time";
public static final ImmutableList<String> SUMMARY_KEYS = ImmutableList.of(PROFILE_ID, TASK_TYPE,
- START_TIME, END_TIME, TOTAL_TIME, TASK_STATE, USER, DEFAULT_DB, SQL_STATEMENT, IS_CACHED,
+ START_TIME, END_TIME, TOTAL_TIME, TASK_STATE, USER, DEFAULT_DB, SQL_STATEMENT, IS_NEREIDS, IS_CACHED,
TOTAL_INSTANCES_NUM, INSTANCES_NUM_PER_BE, PARALLEL_FRAGMENT_EXEC_INSTANCE, TRACE_ID);
public static final ImmutableList<String> EXECUTION_SUMMARY_KEYS = ImmutableList.of(ANALYSIS_TIME, PLAN_TIME,
@@ -229,6 +230,11 @@ public class SummaryProfile {
return this;
}
+ public SummaryBuilder enableNereids(String enableNereids) {
+ map.put(IS_NEREIDS, enableNereids);
+ return this;
+ }
+
public Map<String, String> build() {
return map;
}
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 47f3460f20..fc7187592e 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
@@ -315,6 +315,7 @@ public class StmtExecutor {
.collect(Collectors.joining(",")));
builder.parallelFragmentExecInstance(String.valueOf(context.sessionVariable.getParallelExecInstanceNum()));
builder.traceId(context.getSessionVariable().getTraceId());
+ builder.enableNereids(context.getState().isNereids ? "Yes" : "No");
return builder.build();
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org