TASKS
tasks
Name
tasks
description
表函数，生成 tasks 临时表，可以查看当前 doris 集群中的 job 产生的 tasks 信息。
该函数用于 from 子句中。
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 |
| Label | TEXT | No | false | NULL | NONE |
| Status | TEXT | No | false | NULL | NONE |
| EtlInfo | TEXT | No | false | NULL | NONE |
| TaskInfo | TEXT | No | false | NULL | NONE |
| ErrorMsg | TEXT | No | false | NULL | NONE |
| CreateTimeMs | TEXT | No | false | NULL | NONE |
| FinishTimeMs | TEXT | No | false | NULL | NONE |
| TrackingUrl | TEXT | No | false | NULL | NONE |
| LoadStatistic | TEXT | No | false | NULL | NONE |
| User | TEXT | No | false | NULL | NONE |
+---------------+------+------+-------+---------+-------+
12 rows in set (0.01 sec)
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
