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:42 UTC
[doris] branch add_is_nereids_in_profile created (now 93d108cf33)
This is an automated email from the ASF dual-hosted git repository.
morrysnow pushed a change to branch add_is_nereids_in_profile
in repository https://gitbox.apache.org/repos/asf/doris.git
at 93d108cf33 [opt](profile) add whether use Nereids info in Profile
This branch includes the following new commits:
new 93d108cf33 [opt](profile) add whether use Nereids info in Profile
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org
[doris] 01/01: [opt](profile) add whether use Nereids info in Profile
Posted by mo...@apache.org.
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