database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[opt](profile) Add ExecutedByFrontend in profile #39942 (#40012)

Browse Source 
cherry pick from #39942
This commit is contained in:
zhiqiang
2024-08-28 22:06:57 +08:00
committed by GitHub
parent 7ffbead040
commit c9aca7d852
3 changed files with 102 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -60,7 +60,7 @@ public class SummaryProfile {
public static final String PARALLEL_FRAGMENT_EXEC_INSTANCE = "Parallel Fragment Exec Instance Num";
public static final String TRACE_ID = "Trace ID";
public static final String WORKLOAD_GROUP = "Workload Group";
public static final String EXECUTED_BY_FRONTEND = "Executed By Frontend";
// Execution Summary
public static final String EXECUTION_SUMMARY_PROFILE_NAME = "Execution Summary";
public static final String ANALYSIS_TIME = "Analysis Time";
@ -151,7 +151,8 @@ public class SummaryProfile {
INSTANCES_NUM_PER_BE,
PARALLEL_FRAGMENT_EXEC_INSTANCE,
TRACE_ID,
TRANSACTION_COMMIT_TIME
TRANSACTION_COMMIT_TIME,
EXECUTED_BY_FRONTEND
);
// Ident of each item. Default is 0, which doesn't need to present in this Map.
@ -746,4 +747,8 @@ public class SummaryProfile {
}
return new Gson().toJson(jsonObject);
}
public void setExecutedByFrontend(boolean executedByFrontend) {
summaryProfile.addInfoString(EXECUTED_BY_FRONTEND, String.valueOf(executedByFrontend));
}
}

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

@ -1704,6 +1704,11 @@ public class StmtExecutor {
sendResultSet(resultSet.get(), ((Queriable) parsedStmt).getFieldInfos());
isHandleQueryInFe = true;
LOG.info("Query {} finished", DebugUtil.printId(context.queryId));
if (context.getSessionVariable().enableProfile()) {
if (profile != null) {
this.profile.getSummaryProfile().setExecutedByFrontend(true);
}
}
return;
}
}