TASKS
tasks
Name
tasks
description
表函数,生成 tasks 临时表,可以查看当前 doris 集群中的 job 产生的 tasks 信息。
该函数用于 from 子句中。
该函数自 2.1.0 版本支持。
syntax
tasks("type"="insert");
参数说明
参数名 | 说明 | 类型 | 是否必填 |
---|---|---|---|
type | 作业类型 | string | 是 |
type 支持的类型:
- insert:insert into 类型的任务。
- mv: mv 类型的任务
Insert tasks
tasks("type"="insert");
表结构:
mysql> desc function tasks("type"="insert");;
+---------------+------+------+-------+---------+-------+
| Field | Type | Null | Key | Default | Extra |
+---------------+------+------+-------+---------+-------+
| TaskId | TEXT | No | false | NULL | NONE |
| JobId | TEXT | No | false | NULL | NONE |
| JobName | TEXT | No | false | NULL | NONE |
| Label | TEXT | No | false | NULL | NONE |
| Status | TEXT | No | false | NULL | NONE |
| ErrorMsg | TEXT | No | false | NULL | NONE |
| CreateTime | TEXT | No | false | NULL | NONE |
| FinishTime | TEXT | No | false | NULL | NONE |
| TrackingUrl | TEXT | No | false | NULL | NONE |
| LoadStatistic | TEXT | No | false | NULL | NONE |
| User | TEXT | No | false | NULL | NONE |
+---------------+------+------+-------+---------+-------+
11 row in set (0.01 sec)
- TaskId:task id
- JobId:job id
- JobName:job 名称
- Label:label
- Status:task 状态
- ErrorMsg:task 失败信息
- CreateTime:task 创建时间
- FinishTime:task 结束时间
- TrackingUrl:task tracking url
- LoadStatistic:task 统计信息
- User:执行用户
MV tasks
mysql> desc function tasks("type"="mv");
+-----------------------+------+------+-------+---------+-------+
| Field | Type | Null | Key | Default | Extra |
+-----------------------+------+------+-------+---------+-------+
| TaskId | TEXT | No | false | NULL | NONE |
| JobId | TEXT | No | false | NULL | NONE |
| JobName | TEXT | No | false | NULL | NONE |
| MvId | TEXT | No | false | NULL | NONE |
| MvName | TEXT | No | false | NULL | NONE |
| MvDatabaseId | TEXT | No | false | NULL | NONE |
| MvDatabaseName | TEXT | No | false | NULL | NONE |
| Status | TEXT | No | false | NULL | NONE |
| ErrorMsg | TEXT | No | false | NULL | NONE |
| CreateTime | TEXT | No | false | NULL | NONE |
| StartTime | TEXT | No | false | NULL | NONE |
| FinishTime | TEXT | No | false | NULL | NONE |
| DurationMs | TEXT | No | false | NULL | NONE |
| TaskContext | TEXT | No | false | NULL | NONE |
| RefreshMode | TEXT | No | false | NULL | NONE |
| NeedRefreshPartitions | TEXT | No | false | NULL | NONE |
| CompletedPartitions | TEXT | No | false | NULL | NONE |
| Progress | TEXT | No | false | NULL | NONE |
+-----------------------+------+------+-------+---------+-------+
18 rows in set (0.00 sec)
- TaskId:task id
- JobId:job id
- JobName:job 名称
- MvId:物化视图 id
- MvName:物化视图名称
- MvDatabaseId:物化视图所属 db id
- MvDatabaseName:物化视图所属 db 名称
- Status:task 状态
- ErrorMsg:task 失败信息
- CreateTime:task 创建时间
- StartTime:task 开始运行时间
- FinishTime:task 结束运行时间
- DurationMs:task 运行时间
- TaskContext:task 运行参数
- RefreshMode:刷新模式
- NeedRefreshPartitions:本次 task 需要刷新的分区信息
- CompletedPartitions:本次 task 刷新完成的分区信息
- Progress:task 运行进度
example
Insert Tasks
mysql> select * from tasks("type"="insert") limit 1 \G
*************************** 1. row ***************************
TaskId: 667704038678903
JobId: 10069
Label: 10069_667704038678903
Status: FINISHED
EtlInfo: \N
TaskInfo: cluster:N/A; timeout(s):14400; max_filter_ratio:0.0; priority:NORMAL
ErrorMsg: \N
CreateTimeMs: 2023-12-08 16:46:57
FinishTimeMs: 2023-12-08 16:46:57
TrackingUrl:
LoadStatistic: {"Unfinished backends":{},"ScannedRows":0,"TaskNumber":0,"LoadBytes":0,"All backends":{},"FileNumber":0,"FileSize":0}
User: root
1 row in set (0.05 sec)
MV Tasks
- 查看所有物化视图的 task
mysql> select * from tasks("type"="mv");
- 查看 jobName 为
inner_mtmv_75043
的所有 task
mysql> select * from tasks("type"="mv") where JobName="inner_mtmv_75043";
keywords
tasks, job, insert, mv, materilized view