タスク
説明
テーブル関数で、タスクの一時テーブルを生成し、現在のDorisクラスター内のジョブによって生成されたタスクの情報を表示することができます。
構文
TASKS(
"type"="<type>"
)
パラメータ
| パラメータ | 説明 |
|---|---|
<type> | タスクのタイプ: insert: insert タイプのタスク。 mv: materialized view タイプのタスク。 |
戻り値
このテーブル関数は0行以上の行を返します。関数自体はNULLを返しません。対応するタスクメタデータが利用できない場合、個々のフィールドは空、NULL、または\Nになる可能性があります。
-
tasks("type"="insert")insert タイプのタスクの戻り値フィールド名 説明 TaskId タスクID JobId ジョブID JobName ジョブ名 Label ラベル Status タスクステータス ErrorMsg タスク失敗情報 CreateTime タスク作成時間 FinishTime タスク完了時間 TrackingUrl トラッキングURL LoadStatistic ロード統計 User ユーザー -
tasks("type"="mv")MV タイプのタスクの戻り値フィールド名 説明 TaskId リフレッシュタスクの一意ID。各materialized viewリフレッシュは新しいタスクレコードを作成します。 JobId このタスクを生成したジョブのID。 jobs("type"="mv").Idに対応します。JobName このタスクを生成したジョブの名前。 mv_infos("database"="...").JobNameとjobs("type"="mv").Nameに対応します。MvId このタスクによってリフレッシュされるmaterialized viewのID。 MvName このタスクによってリフレッシュされるmaterialized viewの名前。 MvDatabaseId materialized viewを含むデータベースのID。 MvDatabaseName materialized viewを含むデータベースの名前。 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はすべてのmaterialized viewパーティションがリフレッシュされたことを意味し、PARTIALは一部のパーティションのみがリフレッシュされたことを意味し、NOT_REFRESHはリフレッシュが必要なパーティションがなかったことを意味します。NeedRefreshPartitions このタスクでリフレッシュが必要だったmaterialized viewパーティションの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フィールドは、materialized viewリフレッシュタスクをチェックする際によく使用されます：
Status：タスクのライフサイクル状態。PENDING：タスクは作成されましたが、まだ実行を開始していません。スケジューリングまたはリソースを待機中です。RUNNING：タスクは現在実行中です。SUCCESS：タスクは正常に完了しました。FAILED：タスクは失敗しました。まずErrorMsgを確認し、空でない場合はLastQueryIdを使用してログを検索してください。CANCELED：タスクは完了前にキャンセルされました。
TaskContext.triggerMode：このタスクが作成された理由。MANUAL：REFRESH MATERIALIZED VIEWなどの手動リフレッシュコマンドによって作成されました。COMMIT：関連するベーステーブルのデータ変更がリフレッシュをトリガーしたために作成されました。SYSTEM：内部システムアクションによって作成されました。例えば、即座にビルドされるように作成されたmaterialized viewの初期ビルドなどです。
TaskContext.isComplete：リフレッシュ要求が完全なリフレッシュを求めているかどうか。true：要求はDorisにすべてのmaterialized viewパーティションをリフレッシュするよう求めています。false：要求は完全なリフレッシュを強制しません。Dorisはパーティションの新しさに基づいて実際のリフレッシュ範囲を決定できます。
RefreshMode：パーティションをチェックした後にタスクによって選択された実際のリフレッシュ範囲。COMPLETE：MVに属するすべてのmaterialized viewパーティションがリフレッシュ対象として選択されました。PARTIAL：一部のmaterialized viewパーティションのみがリフレッシュ対象として選択されました。NOT_REFRESH：リフレッシュが必要なパーティションはありませんでした。この場合、NeedRefreshPartitionsは通常空で、Progressは\Nになることがあります。
Version
LastQueryIdはDoris 3.0.0以降でサポートされています。Doris 2.1.xでは利用できません。
例
materialized viewの最新のリフレッシュタスクを表示します。
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 |
+----------------+----------------+----------------+-------------------------------+---------+----------+---------------------+---------------------+---------------------+-------------+---------------+------+