バージョン: 4.x

タスク

説明

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

構文

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

Parameters

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

Return Value

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

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

Field Name	Description
TaskId	タスクid
JobId	ジョブid
JobName	ジョブ名
Label	ラベル
Status	タスクステータス
ErrorMsg	タスク失敗情報
CreateTime	タスク作成時刻
FinishTime	タスク完了時刻
TrackingUrl	トラッキングURL
LoadStatistic	ロード統計
User	ユーザー

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

Field Name	Description
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`になることがあります。
LastQueryId	リフレッシュタスクによって実行されたSQL文のクエリID。タスクの失敗をトラブルシューティングする際にFEまたはBEログを検索するためにこのIDを使用します。リフレッシュSQLが実行されなかった場合は空になることがあります。このフィールドはDoris 3.0.0以降でサポートされています。

MVタスクenumフィールド

マテリアライズドビューリフレッシュタスクをチェックする際に一般的に使用される以下のenumフィールド:

Status: タスクのライフサイクル状態。
- PENDING: タスクは作成されましたが、まだ実行を開始していません。スケジューリングまたはリソースを待機しています。
- RUNNING: タスクは現在実行中です。
- SUCCESS: タスクは正常に完了しました。
- FAILED: タスクが失敗しました。まずErrorMsgを確認し、空でなければLastQueryIdを使用してログを検索してください。
- 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

LastQueryIdはDoris 3.0.0以降でサポートされています。Doris 2.1.xでは利用できません。

Examples

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

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)
          LastQueryId: 7965b4ddce8a4480-8884e9701679c1c4

この結果では：

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つが完了したことを意味します。
LastQueryIdはリフレッシュSQLのクエリIDです。タスクが失敗したり実行が遅い場合に、Dorisログを検索するために使用します。

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 |
+----------------+----------------+----------------+-------------------------------+---------+----------+---------------------+---------------------+---------------------+-------------+---------------+------+

説明​

構文​

Parameters​

Return Value​

MVタスクenumフィールド​

Examples​

説明

構文

Parameters

Return Value

MVタスクenumフィールド

Examples