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 <[email protected]> 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: [email protected] For additional commands, e-mail: [email protected]
