This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch branch-1.2-lts
in repository https://gitbox.apache.org/repos/asf/doris.git
commit e0824e552674e3c5962996bdee3be8017c4c816a
Author: xueweizhang <zxw520bl...@163.com>
AuthorDate: Thu Mar 9 11:58:40 2023 +0800
[fix](profile) modify load profile some bugs and docs (#17533)
1. 'insert into' profile has 'insert' type, can not query by 'load' type
2. 'insert into' profile does not have job_id, can not query by job_id. so
put all profiles key with query_id
3. 'broker load' profile does not have some infos, npe
---
.../docs/advanced/best-practice/import-analysis.md | 75 +++++++++++++++-------
.../Show-Statements/SHOW-LOAD-PROFILE.md | 50 ++++++++++++---
.../docs/advanced/best-practice/import-analysis.md | 57 ++++++++++++----
.../Show-Statements/SHOW-LOAD-PROFILE.md | 52 +++++++++++----
.../apache/doris/analysis/ShowLoadProfileStmt.java | 16 ++---
.../apache/doris/common/util/ProfileManager.java | 8 +--
.../httpv2/controller/QueryProfileController.java | 2 +-
.../java/org/apache/doris/qe/ShowExecutor.java | 2 +-
.../java/org/apache/doris/qe/StmtExecutor.java | 2 +-
9 files changed, 191 insertions(+), 73 deletions(-)
diff --git a/docs/en/docs/advanced/best-practice/import-analysis.md
b/docs/en/docs/advanced/best-practice/import-analysis.md
index 793c7beef0..967e21a38a 100644
--- a/docs/en/docs/advanced/best-practice/import-analysis.md
+++ b/docs/en/docs/advanced/best-practice/import-analysis.md
@@ -68,12 +68,43 @@ Then submit a Broker Load import request and wait until the
import execution com
We can get the Profile list first with the following command:
```sql
-mysql> show load profile "/";
-+---------+------+-----------+------+------------+-
--------------------+---------------------------------+-------
----+------------+
-| QueryId | User | DefaultDb | SQL | QueryType | StartTime | EndTime |
TotalTime | QueryState |
-+---------+------+-----------+------+------------+-
--------------------+---------------------------------+-------
----+------------+
-| 10441 | N/A | N/A | N/A | Load | 2021-04-10 22:15:37 | 2021-04-10 22:18:54 |
3m17s | N/A |
-+---------+------+-----------+------+------------+-
--------------------+---------------------------------+-------
----+------------+
+mysql> show load profile "/"\G
+*************************** 1. row ***************************
+ JobId: 20010
+ QueryId: 980014623046410a-af5d36f23381017f
+ User: root
+ DefaultDb: default_cluster:test
+ SQL: LOAD LABEL xxx
+ QueryType: Load
+ StartTime: 2023-03-07 19:48:24
+ EndTime: 2023-03-07 19:50:45
+ TotalTime: 2m21s
+ QueryState: N/A
+ TraceId:
+ AnalysisTime: NULL
+ PlanTime: NULL
+ ScheduleTime: NULL
+ FetchResultTime: NULL
+ WriteResultTime: NULL
+WaitAndFetchResultTime: NULL
+*************************** 2. row ***************************
+ JobId: N/A
+ QueryId: 7cc2d0282a7a4391-8dd75030185134d8
+ User: root
+ DefaultDb: default_cluster:test
+ SQL: insert into xxx
+ QueryType: Load
+ StartTime: 2023-03-07 19:49:15
+ EndTime: 2023-03-07 19:49:15
+ TotalTime: 102ms
+ QueryState: OK
+ TraceId:
+ AnalysisTime: 825.277us
+ PlanTime: 4.126ms
+ ScheduleTime: N/A
+ FetchResultTime: 0ns
+ WriteResultTime: 0ns
+WaitAndFetchResultTime: N/A
````
This command will list all currently saved import profiles. Each line
corresponds to one import. where the QueryId column is the ID of the import
job. This ID can also be viewed through the SHOW LOAD statement. We can select
the QueryId corresponding to the Profile we want to see to see the specific
situation.
@@ -87,15 +118,15 @@ This command will list all currently saved import
profiles. Each line correspond
```sql
- mysql> show load profile "/10441";
+ mysql> show load profile "/980014623046410a-af5d36f23381017f";
+-----------------------------------+------------+
- | TaskId | ActiveTime |
+ | TaskId | ActiveTime |
+-----------------------------------+------------+
- | 980014623046410a-88e260f0c43031f1 | 3m14s |
+ | 980014623046410a-af5d36f23381017f | 3m14s |
+-----------------------------------+------------+
````
-As shown in the figure above, it means that the import job 10441 has a total
of one subtask, in which ActiveTime indicates the execution time of the longest
instance in this subtask.
+As shown in the figure above, it means that the import job
`980014623046410a-af5d36f23381017f` has a total of one subtask, in which
ActiveTime indicates the execution time of the longest instance in this subtask.
2. View the Instance overview of the specified subtask
@@ -104,18 +135,18 @@ As shown in the figure above, it means that the import
job 10441 has a total of
```sql
- mysql> show load profile "/10441/980014623046410a-88e260f0c43031f1";
- +-----------------------------------+------------- -----+------------+
- | Instances | Host | ActiveTime |
- +-----------------------------------+------------- -----+------------+
- | 980014623046410a-88e260f0c43031f2 | 10.81.85.89:9067 | 3m7s |
- | 980014623046410a-88e260f0c43031f3 | 10.81.85.89:9067 | 3m6s |
- | 980014623046410a-88e260f0c43031f4 | 10.81.85.89:9067 | 3m10s |
- | 980014623046410a-88e260f0c43031f5 | 10.81.85.89:9067 | 3m14s |
- +-----------------------------------+------------- -----+------------+
+ mysql> show load profile
"/980014623046410a-af5d36f23381017f/980014623046410a-af5d36f23381017f";
+ +-----------------------------------+------------------+------------+
+ | Instances | Host | ActiveTime |
+ +-----------------------------------+------------------+------------+
+ | 980014623046410a-88e260f0c43031f2 | 10.81.85.89:9067 | 3m7s |
+ | 980014623046410a-88e260f0c43031f3 | 10.81.85.89:9067 | 3m6s |
+ | 980014623046410a-88e260f0c43031f4 | 10.81.85.89:9067 | 3m10s |
+ | 980014623046410a-88e260f0c43031f5 | 10.81.85.89:9067 | 3m14s |
+ +-----------------------------------+------------------+------------+
````
-This shows the time-consuming of four instances of the subtask
980014623046410a-88e260f0c43031f1, and also shows the execution node where the
instance is located.
+This shows the time-consuming of four instances of the subtask
980014623046410a-af5d36f23381017f, and also shows the execution node where the
instance is located.
3. View the specific Instance
@@ -124,7 +155,7 @@ This shows the time-consuming of four instances of the
subtask 980014623046410a-
```sql
- mysql> show load profile
"/10441/980014623046410a-88e260f0c43031f1/980014623046410a-88e260f0c43031f5"\G
+ mysql> show load profile
"/980014623046410a-af5d36f23381017f/980014623046410a-af5d36f23381017f/980014623046410a-88e260f0c43031f5"\G
**************************** 1. row ******************** ******
Instance:
┌-----------------------------------------┐
@@ -166,6 +197,6 @@ This shows the time-consuming of four instances of the
subtask 980014623046410a-
└------------------------------------------------- ----┘
````
-The figure above shows the specific profiles of each operator of Instance
980014623046410a-88e260f0c43031f5 in subtask 980014623046410a-88e260f0c43031f1.
+The figure above shows the specific profiles of each operator of Instance
980014623046410a-af5d36f23381017f in subtask 980014623046410a-88e260f0c43031f5.
Through the above three steps, we can gradually check the execution bottleneck
of an import task.
diff --git
a/docs/en/docs/sql-manual/sql-reference/Show-Statements/SHOW-LOAD-PROFILE.md
b/docs/en/docs/sql-manual/sql-reference/Show-Statements/SHOW-LOAD-PROFILE.md
index 1382f81642..d17e1cb0ce 100644
--- a/docs/en/docs/sql-manual/sql-reference/Show-Statements/SHOW-LOAD-PROFILE.md
+++ b/docs/en/docs/sql-manual/sql-reference/Show-Statements/SHOW-LOAD-PROFILE.md
@@ -59,30 +59,60 @@ This command will list all currently saved import profiles.
Each line correspond
1. List all Load Profiles
```sql
- mysql> show load profile "/";
-
+---------+------+-----------+------+-----------+---------------------+---------------------+-----------+------------+
- | QueryId | User | DefaultDb | SQL | QueryType | StartTime |
EndTime | TotalTime | QueryState |
-
+---------+------+-----------+------+-----------+---------------------+---------------------+-----------+------------+
- | 10441 | N/A | N/A | N/A | Load | 2021-04-10 22:15:37 |
2021-04-10 22:18:54 | 3m17s | N/A |
-
+---------+------+-----------+------+-----------+---------------------+---------------------+-----------+------------+
- 2 rows in set (0.00 sec)
+ mysql> show load profile "/"\G
+*************************** 1. row ***************************
+ JobId: 20010
+ QueryId: 980014623046410a-af5d36f23381017f
+ User: root
+ DefaultDb: default_cluster:test
+ SQL: LOAD LABEL xxx
+ QueryType: Load
+ StartTime: 2023-03-07 19:48:24
+ EndTime: 2023-03-07 19:50:45
+ TotalTime: 2m21s
+ QueryState: N/A
+ TraceId:
+ AnalysisTime: NULL
+ PlanTime: NULL
+ ScheduleTime: NULL
+ FetchResultTime: NULL
+ WriteResultTime: NULL
+WaitAndFetchResultTime: NULL
+*************************** 2. row ***************************
+ JobId: N/A
+ QueryId: 7cc2d0282a7a4391-8dd75030185134d8
+ User: root
+ DefaultDb: default_cluster:test
+ SQL: insert into xxx
+ QueryType: Load
+ StartTime: 2023-03-07 19:49:15
+ EndTime: 2023-03-07 19:49:15
+ TotalTime: 102ms
+ QueryState: OK
+ TraceId:
+ AnalysisTime: 825.277us
+ PlanTime: 4.126ms
+ ScheduleTime: N/A
+ FetchResultTime: 0ns
+ WriteResultTime: 0ns
+WaitAndFetchResultTime: N/A
````
2. View an overview of the subtasks with imported jobs:
```sql
- mysql> show load profile "/10441";
+ mysql> show load profile "/980014623046410a-af5d36f23381017f";
+-----------------------------------+------------+
| TaskId | ActiveTime |
+-----------------------------------+------------+
- | 980014623046410a-88e260f0c43031f1 | 3m14s |
+ | 980014623046410a-af5d36f23381017f | 3m14s |
+-----------------------------------+------------+
````
3. View the Instance overview of the specified subtask
```sql
- mysql> show load profile "/10441/980014623046410a-88e260f0c43031f1";
+ mysql> show load profile
"/980014623046410a-af5d36f23381017f/980014623046410a-af5d36f23381017f/980014623046410a-88e260f0c43031f5"\G
+-----------------------------------+------------------+------------+
| Instances | Host | ActiveTime |
+-----------------------------------+------------------+------------+
diff --git a/docs/zh-CN/docs/advanced/best-practice/import-analysis.md
b/docs/zh-CN/docs/advanced/best-practice/import-analysis.md
index e120ef34c2..02b1a5e855 100644
--- a/docs/zh-CN/docs/advanced/best-practice/import-analysis.md
+++ b/docs/zh-CN/docs/advanced/best-practice/import-analysis.md
@@ -67,12 +67,43 @@ SET is_report_success=true;
我们可以通过如下命令先获取 Profile 列表：
```sql
-mysql> show load profile "/";
-+---------+------+-----------+------+-----------+---------------------+---------------------+-----------+------------+
-| QueryId | User | DefaultDb | SQL | QueryType | StartTime |
EndTime | TotalTime | QueryState |
-+---------+------+-----------+------+-----------+---------------------+---------------------+-----------+------------+
-| 10441 | N/A | N/A | N/A | Load | 2021-04-10 22:15:37 |
2021-04-10 22:18:54 | 3m17s | N/A |
-+---------+------+-----------+------+-----------+---------------------+---------------------+-----------+------------+
+mysql> show load profile "/"\G
+*************************** 1. row ***************************
+ JobId: 20010
+ QueryId: 980014623046410a-af5d36f23381017f
+ User: root
+ DefaultDb: default_cluster:test
+ SQL: LOAD LABEL xxx
+ QueryType: Load
+ StartTime: 2023-03-07 19:48:24
+ EndTime: 2023-03-07 19:50:45
+ TotalTime: 2m21s
+ QueryState: N/A
+ TraceId:
+ AnalysisTime: NULL
+ PlanTime: NULL
+ ScheduleTime: NULL
+ FetchResultTime: NULL
+ WriteResultTime: NULL
+WaitAndFetchResultTime: NULL
+*************************** 2. row ***************************
+ JobId: N/A
+ QueryId: 7cc2d0282a7a4391-8dd75030185134d8
+ User: root
+ DefaultDb: default_cluster:test
+ SQL: insert into xxx
+ QueryType: Load
+ StartTime: 2023-03-07 19:49:15
+ EndTime: 2023-03-07 19:49:15
+ TotalTime: 102ms
+ QueryState: OK
+ TraceId:
+ AnalysisTime: 825.277us
+ PlanTime: 4.126ms
+ ScheduleTime: N/A
+ FetchResultTime: 0ns
+ WriteResultTime: 0ns
+WaitAndFetchResultTime: N/A
```
这个命令会列出当前保存的所有导入 Profile。每行对应一个导入。其中 QueryId 列为导入作业的 ID。这个 ID 也可以通过 SHOW LOAD
语句查看拿到。我们可以选择我们想看的 Profile 对应的 QueryId，查看具体情况。
@@ -86,15 +117,15 @@ mysql> show load profile "/";
```sql
- mysql> show load profile "/10441";
+ mysql> show load profile "/980014623046410a-af5d36f23381017f";
+-----------------------------------+------------+
| TaskId | ActiveTime |
+-----------------------------------+------------+
- | 980014623046410a-88e260f0c43031f1 | 3m14s |
+ | 980014623046410a-af5d36f23381017f | 3m14s |
+-----------------------------------+------------+
```
- 如上图，表示 10441 这个导入作业总共有一个子任务，其中 ActiveTime 表示这个子任务中耗时最长的 Instance 的执行时间。
+ 如上图，表示 `980014623046410a-af5d36f23381017f` 这个导入作业总共有一个子任务，其中 ActiveTime
表示这个子任务中耗时最长的 Instance 的执行时间。
2. 查看指定子任务的 Instance 概况
@@ -103,7 +134,7 @@ mysql> show load profile "/";
```sql
- mysql> show load profile "/10441/980014623046410a-88e260f0c43031f1";
+ mysql> show load profile
"/980014623046410a-af5d36f23381017f/980014623046410a-af5d36f23381017f";
+-----------------------------------+------------------+------------+
| Instances | Host | ActiveTime |
+-----------------------------------+------------------+------------+
@@ -114,7 +145,7 @@ mysql> show load profile "/";
+-----------------------------------+------------------+------------+
```
- 这里展示了 980014623046410a-88e260f0c43031f1 这个子任务的四个 Instance 耗时，并且还展示了
Instance 所在的执行节点。
+ 这里展示了 980014623046410a-af5d36f23381017f 这个子任务的四个 Instance 耗时，并且还展示了
Instance 所在的执行节点。
3. 查看具体 Instance
@@ -123,7 +154,7 @@ mysql> show load profile "/";
```sql
- mysql> show load profile
"/10441/980014623046410a-88e260f0c43031f1/980014623046410a-88e260f0c43031f5"\G
+ mysql> show load profile
"/980014623046410a-af5d36f23381017f/980014623046410a-af5d36f23381017f/980014623046410a-88e260f0c43031f5"\G
*************************** 1. row ***************************
Instance:
┌-----------------------------------------┐
@@ -165,6 +196,6 @@ mysql> show load profile "/";
└-----------------------------------------------------┘
```
- 上图展示了子任务 980014623046410a-88e260f0c43031f1 中，Instance
980014623046410a-88e260f0c43031f5 的各个算子的具体 Profile。
+ 上图展示了子任务 980014623046410a-af5d36f23381017f 中，Instance
980014623046410a-88e260f0c43031f5 的各个算子的具体 Profile。
通过以上3个步骤，我们可以逐步排查一个导入任务的执行瓶颈。
diff --git
a/docs/zh-CN/docs/sql-manual/sql-reference/Show-Statements/SHOW-LOAD-PROFILE.md
b/docs/zh-CN/docs/sql-manual/sql-reference/Show-Statements/SHOW-LOAD-PROFILE.md
index 763fa5a3db..f53f195b67 100644
---
a/docs/zh-CN/docs/sql-manual/sql-reference/Show-Statements/SHOW-LOAD-PROFILE.md
+++
b/docs/zh-CN/docs/sql-manual/sql-reference/Show-Statements/SHOW-LOAD-PROFILE.md
@@ -59,30 +59,60 @@ show load profile "/[queryId]"
1. 列出所有的 Load Profile
```sql
- mysql> show load profile "/";
-
+---------+------+-----------+------+-----------+---------------------+---------------------+-----------+------------+
- | QueryId | User | DefaultDb | SQL | QueryType | StartTime |
EndTime | TotalTime | QueryState |
-
+---------+------+-----------+------+-----------+---------------------+---------------------+-----------+------------+
- | 10441 | N/A | N/A | N/A | Load | 2021-04-10 22:15:37 |
2021-04-10 22:18:54 | 3m17s | N/A |
-
+---------+------+-----------+------+-----------+---------------------+---------------------+-----------+------------+
- 2 rows in set (0.00 sec)
+ mysql> show load profile "/"\G
+*************************** 1. row ***************************
+ JobId: 20010
+ QueryId: 980014623046410a-af5d36f23381017f
+ User: root
+ DefaultDb: default_cluster:test
+ SQL: LOAD LABEL xxx
+ QueryType: Load
+ StartTime: 2023-03-07 19:48:24
+ EndTime: 2023-03-07 19:50:45
+ TotalTime: 2m21s
+ QueryState: N/A
+ TraceId:
+ AnalysisTime: NULL
+ PlanTime: NULL
+ ScheduleTime: NULL
+ FetchResultTime: NULL
+ WriteResultTime: NULL
+WaitAndFetchResultTime: NULL
+*************************** 2. row ***************************
+ JobId: N/A
+ QueryId: 7cc2d0282a7a4391-8dd75030185134d8
+ User: root
+ DefaultDb: default_cluster:test
+ SQL: insert into xxx
+ QueryType: Load
+ StartTime: 2023-03-07 19:49:15
+ EndTime: 2023-03-07 19:49:15
+ TotalTime: 102ms
+ QueryState: OK
+ TraceId:
+ AnalysisTime: 825.277us
+ PlanTime: 4.126ms
+ ScheduleTime: N/A
+ FetchResultTime: 0ns
+ WriteResultTime: 0ns
+WaitAndFetchResultTime: N/A
```
2. 查看有导入作业的子任务概况：
```sql
- mysql> show load profile "/10441";
+ mysql> show load profile "/980014623046410a-af5d36f23381017f";
+-----------------------------------+------------+
| TaskId | ActiveTime |
+-----------------------------------+------------+
- | 980014623046410a-88e260f0c43031f1 | 3m14s |
+ | 980014623046410a-af5d36f23381017f | 3m14s |
+-----------------------------------+------------+
```
3. 查看指定子任务的 Instance 概况
```sql
- mysql> show load profile "/10441/980014623046410a-88e260f0c43031f1";
+ mysql> show load profile
"/980014623046410a-af5d36f23381017f/980014623046410a-af5d36f23381017f";
+-----------------------------------+------------------+------------+
| Instances | Host | ActiveTime |
+-----------------------------------+------------------+------------+
@@ -96,7 +126,7 @@ show load profile "/[queryId]"
4. 继续查看某一个具体的 Instance 上各个算子的详细 Profile
```sql
- mysql> show load profile
"/10441/980014623046410a-88e260f0c43031f1/980014623046410a-88e260f0c43031f5"\G
+ mysql> show load profile
"/980014623046410a-af5d36f23381017f/980014623046410a-af5d36f23381017f/980014623046410a-88e260f0c43031f5"\G
*************************** 1. row ***************************
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowLoadProfileStmt.java
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowLoadProfileStmt.java
index a30ef18b9f..5175348674 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowLoadProfileStmt.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowLoadProfileStmt.java
@@ -27,9 +27,9 @@ import com.google.common.base.Strings;
// For stmt like:
// show load profile "/"; # list all saving load job ids
-// show load profile "/10014" # show task ids of specified job
-// show load profile "/10014/e0f7390f5363419e-b416a2a79996083e/" # show
instance list of the task
-// show load profile
"/10014/e0f7390f5363419e-b416a2a79996083e/e0f7390f5363419e-b416a2a7999" # show
instance's graph
+// show load profile "/e0f7390f5363419e-xxx" # show task ids of specified job
+// show load profile "/e0f7390f5363419e-xxx/e0f7390f5363419e-yyy/" # show
instance list of the task
+// show load profile
"/e0f7390f5363419e-xxx/e0f7390f5363419e-yyy/e0f7390f5363419e-zzz" # show
instance's graph
public class ShowLoadProfileStmt extends ShowStmt {
private static final ShowResultSetMetaData META_DATA_TASK_IDS =
ShowResultSetMetaData.builder()
@@ -38,7 +38,7 @@ public class ShowLoadProfileStmt extends ShowStmt {
.build();
public enum PathType {
- JOB_IDS,
+ QUERY_IDS,
TASK_IDS,
INSTANCES,
SINGLE_INSTANCE
@@ -76,14 +76,14 @@ public class ShowLoadProfileStmt extends ShowStmt {
super.analyze(analyzer);
if (Strings.isNullOrEmpty(idPath)) {
// list all query ids
- pathType = PathType.JOB_IDS;
+ pathType = PathType.QUERY_IDS;
return;
}
if (!idPath.startsWith("/")) {
throw new AnalysisException("Path must starts with '/'");
}
- pathType = PathType.JOB_IDS;
+ pathType = PathType.QUERY_IDS;
String[] parts = idPath.split("/");
if (parts.length > 4) {
throw new AnalysisException("Path must in format
'/jobId/taskId/instanceId'");
@@ -92,7 +92,7 @@ public class ShowLoadProfileStmt extends ShowStmt {
for (int i = 0; i < parts.length; i++) {
switch (i) {
case 0:
- pathType = PathType.JOB_IDS;
+ pathType = PathType.QUERY_IDS;
continue;
case 1:
jobId = parts[i];
@@ -126,7 +126,7 @@ public class ShowLoadProfileStmt extends ShowStmt {
@Override
public ShowResultSetMetaData getMetaData() {
switch (pathType) {
- case JOB_IDS:
+ case QUERY_IDS:
return ShowQueryProfileStmt.META_DATA_QUERY_IDS;
case TASK_IDS:
return META_DATA_TASK_IDS;
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/common/util/ProfileManager.java
b/fe/fe-core/src/main/java/org/apache/doris/common/util/ProfileManager.java
index 809a8c3c9c..bc7a810e5e 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/common/util/ProfileManager.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/common/util/ProfileManager.java
@@ -163,8 +163,8 @@ public class ProfileManager {
}
ProfileElement element = createElement(profile);
- String key = isQueryProfile(profile) ?
element.infoStrings.get(ProfileManager.QUERY_ID)
- : element.infoStrings.get(ProfileManager.JOB_ID);
+ // 'insert into' does have job_id, put all profiles key with query_id
+ String key = element.infoStrings.get(ProfileManager.QUERY_ID);
// check when push in, which can ensure every element in the list has
QUERY_ID column,
// so there is no need to check when remove element from list.
if (Strings.isNullOrEmpty(key)) {
@@ -349,8 +349,4 @@ public class ProfileManager {
readLock.unlock();
}
}
-
- public boolean isQueryProfile(RuntimeProfile profile) {
- return "Query".equals(profile.getName());
- }
}
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/httpv2/controller/QueryProfileController.java
b/fe/fe-core/src/main/java/org/apache/doris/httpv2/controller/QueryProfileController.java
index 53744f4fc8..7a686ef923 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/httpv2/controller/QueryProfileController.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/httpv2/controller/QueryProfileController.java
@@ -45,7 +45,7 @@ public class QueryProfileController extends BaseController {
private static final String ID = "id";
private static final String DETAIL_COL = "Detail";
- private static final Set<String> QUERY_ID_TYPES = ImmutableSet.of("Query",
"Insert");
+ private static final Set<String> QUERY_ID_TYPES = ImmutableSet.of("Query",
"Load");
@RequestMapping(path = "/query_profile/{" + ID + "}", method =
RequestMethod.GET)
public Object profile(@PathVariable(value = ID) String id) {
diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/ShowExecutor.java
b/fe/fe-core/src/main/java/org/apache/doris/qe/ShowExecutor.java
index 75267c565b..c93807ef2e 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/qe/ShowExecutor.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/qe/ShowExecutor.java
@@ -2042,7 +2042,7 @@ public class ShowExecutor {
ShowLoadProfileStmt.PathType pathType = showStmt.getPathType();
List<List<String>> rows = Lists.newArrayList();
switch (pathType) {
- case JOB_IDS:
+ case QUERY_IDS:
rows =
ProfileManager.getInstance().getQueryWithType(ProfileManager.ProfileType.LOAD);
break;
case TASK_IDS: {
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 2f53b3ccb6..be97ec39b6 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
@@ -554,7 +554,7 @@ public class StmtExecutor implements ProfileWriter {
try {
handleInsertStmt();
if (!((InsertStmt) parsedStmt).getQueryStmt().isExplain())
{
- queryType = "Insert";
+ queryType = "Load";
}
} catch (Throwable t) {
LOG.warn("handle insert stmt fail: {}", t.getMessage());
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
