バージョン: 2.1

タスク

説明

テーブル関数で、タスクの一時テーブルを生成し、現在のDorisクラスター内のジョブによって生成されたタスクの情報を表示することができます。

構文

TASKS(
    "type"="<type>"
)

パラメータ

パラメータ	説明
`<type>`	タスクのタイプ: `insert`: insert タイプのタスク。 `mv`: マテリアライズドビュータイプのタスク。

戻り値

このテーブル関数は0行以上を返します。関数自体はNULLを返しません。対応するタスクメタデータが利用できない場合、個々のフィールドは空、NULL、または\Nになることがあります。

tasks("type"="insert") insert タイプのタスクの戻り値

フィールド名	説明
TaskId	タスクID
JobId	ジョブID
JobName	ジョブ名
Label	ラベル
Status	タスクステータス
ErrorMsg	タスク失敗情報
CreateTime	タスク作成時刻
FinishTime	タスク完了時刻
TrackingUrl	Tracking URL
LoadStatistic	ロード統計
User	ユーザー

tasks("type"="mv") MV タイプのタスクの戻り値

フィールド名	説明
TaskId	リフレッシュタスクの一意ID。各マテリアライズドビューのリフレッシュは新しいタスクレコードを作成します。
JobId	このタスクを生成したジョブのID。`jobs("type"="mv").Id`に対応します。
JobName	このタスクを生成したジョブの名前。`mv_infos("database"="...").JobName`と`jobs("type"="mv").Name`に対応します。
MvId	このタスクによってリフレッシュされるマテリアライズドビューのID。
MvName	このタスクによってリフレッシュされるマテリアライズドビューの名前。
MvDatabaseId	マテリアライズドビューを含むデータベースのID。
MvDatabaseName	マテリアライズドビューを含むデータベースの名前。
Status	タスクステータス。可能な値：`PENDING`はタスクが実行待ちであることを意味します；`RUNNING`はタスクが実行中であることを意味します；`SUCCESS`はタスクが正常に完了したことを意味します；`FAILED`はタスクが失敗したことを意味します；`CANCELED`はタスクがキャンセルされたことを意味します。
ErrorMsg	`Status`が`FAILED`または`CANCELED`の場合のエラーメッセージ。タスクが成功した場合は空です。
CreateTime	タスクレコードが作成された時刻。
StartTime	タスクが実行を開始した時刻。タスクが開始されていない場合は`\N`になることがあります。
FinishTime	タスクが完了した時刻。タスクがまだ待機中または実行中の場合は`\N`になることがあります。
DurationMs	`FinishTime - StartTime`として計算される実行時間（ミリ秒）。タスクが完了していない場合は`\N`になることがあります。
TaskContext	タスクがどのようにトリガーされ、ユーザーが何をリクエストしたかを説明するJSON文字列。一般的なフィールドには`triggerMode`、`partitions`、`isComplete`があります。`triggerMode`の値は`MANUAL`、`COMMIT`、`SYSTEM`です。
RefreshMode	このタスクによって決定される実際のリフレッシュ範囲。可能な値：`COMPLETE`はすべてのマテリアライズドビューパーティションがリフレッシュされたことを意味します；`PARTIAL`は一部のパーティションのみがリフレッシュされたことを意味します；`NOT_REFRESH`はリフレッシュが必要なパーティションがなかったことを意味します。
NeedRefreshPartitions	このタスクでリフレッシュが必要だったマテリアライズドビューパーティションのJSON配列。空の配列はリフレッシュが必要なパーティションがなかったことを意味します。
CompletedPartitions	正常にリフレッシュされたパーティションのJSON配列。`NeedRefreshPartitions`と比較して、すべての必要なパーティションが完了したかどうかを確認できます。
Progress	`percentage (completed/total)`形式のリフレッシュ進行状況、例：`100.00% (1/1)`。リフレッシュするパーティションがない場合は`\N`になることがあります。

MV タスクの列挙フィールド

以下の列挙フィールドは、マテリアライズドビューのリフレッシュタスクをチェックする際によく使用されます：

Status：タスクのライフサイクル状態。
- PENDING：タスクが作成されたが、まだ実行を開始していません。スケジューリングまたはリソースを待っています。
- RUNNING：タスクが現在実行中です。
- SUCCESS：タスクが正常に完了しました。
- FAILED：タスクが失敗しました。まずErrorMsgを確認してください。Doris 2.1.xでは、タスクの時刻フィールドとマテリアライズドビュー名を使用してFEまたはBEログで詳細を検索してください。
- CANCELED：タスクが完了前にキャンセルされました。
TaskContext.triggerMode：このタスクが作成された理由。
- MANUAL：REFRESH MATERIALIZED VIEWなどの手動リフレッシュコマンドによって作成されました。
- COMMIT：関連するベーステーブルのデータ変更がリフレッシュをトリガーしたため作成されました。
- SYSTEM：内部システムアクションによって作成されました。例えば、即座にビルドするように作成されたマテリアライズドビューの初期ビルドなど。
TaskContext.isComplete：リフレッシュリクエストが完全リフレッシュを要求するかどうか。
- true：リクエストはDorisにすべてのマテリアライズドビューパーティションをリフレッシュするよう要求します。
- false：リクエストは完全リフレッシュを強制しません。Dorisはパーティションの新しさに基づいて実際のリフレッシュ範囲を決定できます。
RefreshMode：パーティションをチェックした後にタスクによって選択される実際のリフレッシュ範囲。
- COMPLETE：MVに属するすべてのマテリアライズドビューパーティションがリフレッシュ対象として選択されました。
- PARTIAL：一部のマテリアライズドビューパーティションのみがリフレッシュ対象として選択されました。
- NOT_REFRESH：リフレッシュが必要なパーティションがありませんでした。この場合、NeedRefreshPartitionsは通常空で、Progressは\Nになることがあります。

Version

Doris 2.1.xではtasks("type"="mv")でLastQueryIdを提供しません。リフレッシュ失敗のトラブルシューティングには、ErrorMsg、CreateTime、StartTime、FinishTime、MvDatabaseName、MvNameを使用して関連するFEまたはBEログを見つけてください。

例

マテリアライズドビューの最新のリフレッシュタスクを表示します。

select *
from tasks("type"="mv")
where MvDatabaseName = "test" and MvName = "mv1"
order by CreateTime desc
limit 1\G

*************************** 1. row ***************************
               TaskId: 437156301250803
                JobId: 19508
              JobName: inner_mtmv_19494
                 MvId: 19494
               MvName: mv1
         MvDatabaseId: 16016
       MvDatabaseName: test
               Status: SUCCESS
             ErrorMsg:
           CreateTime: 2025-01-07 22:13:48
            StartTime: 2025-01-07 22:13:48
           FinishTime: 2025-01-07 22:17:45
           DurationMs: 236985
          TaskContext: {"triggerMode":"MANUAL","partitions":[],"isComplete":false}
          RefreshMode: COMPLETE
NeedRefreshPartitions: ["p_20210101_MAXVALUE","p_20200101_20210101"]
  CompletedPartitions: ["p_20210101_MAXVALUE","p_20200101_20210101"]
             Progress: 100.00% (2/2)

この結果では:

TaskIdはこのリフレッシュ実行を識別します。リフレッシュごとに異なります。
JobIdとJobNameはMVリフレッシュジョブを識別します。このジョブはselect * from jobs("type"="mv") where Name = "inner_mtmv_19494";でクエリできます。
MvId、MvName、MvDatabaseId、MvDatabaseNameは、タスクによってリフレッシュされるマテリアライズドビューを識別します。
StatusはSUCCESSなので、タスクは正常に完了しました。FAILEDの場合は、まずErrorMsgを確認してください。
CreateTime、StartTime、FinishTime、DurationMsは、タスクがいつ作成され、いつ開始され、いつ完了し、どの程度の時間実行されたかを示します。
TaskContextは、このタスクが手動でトリガーされたことを示します。partitions: []は、ユーザーがリフレッシュコマンドでパーティションリストを指定しなかったことを意味します。
RefreshModeはCOMPLETEなので、このタスクはマテリアライズドビューがリフレッシュする必要があったすべてのパーティションをリフレッシュしました。
NeedRefreshPartitionsはリフレッシュが必要な2つのパーティションをリストし、CompletedPartitionsは同じ2つのパーティションをリストしているため、必要なパーティションがすべて完了しています。
Progressは100.00% (2/2)で、これも必要な2つのパーティションのうち2つが完了したことを意味します。

Note

保存・表示されるタスクレコード数は、FE設定項目max_persistence_task_countによって制御されます。デフォルト値は100です。タスクレコード数がこの制限を超えると、古いタスクレコードが破棄されます。値が1未満の場合、タスクレコードは永続化されません。この設定を変更した後はFEを再起動してください。

すべてのinsertタスクのタスクを表示

select * from tasks("type"="insert");

+----------------+----------------+----------------+-------------------------------+---------+----------+---------------------+---------------------+---------------------+-------------+---------------+------+
| TaskId         | JobId          | JobName        | Label                         | Status  | ErrorMsg | CreateTime          | StartTime           | FinishTime          | TrackingUrl | LoadStatistic | User |
+----------------+----------------+----------------+-------------------------------+---------+----------+---------------------+---------------------+---------------------+-------------+---------------+------+
| 79133848479750 | 78533940810334 | insert_tab_job | 78533940810334_79133848479750 | SUCCESS |          | 2025-01-17 14:42:54 | 2025-01-17 14:42:54 | 2025-01-17 14:42:54 |             |               | root |
+----------------+----------------+----------------+-------------------------------+---------+----------+---------------------+---------------------+---------------------+-------------+---------------+------+

説明​

構文​

パラメータ​

戻り値​

MV タスクの列挙フィールド​

例​

説明

構文

パラメータ

戻り値

MV タスクの列挙フィールド

例