メインコンテンツまでスキップ

SUBMIT TASK

説明​

ETL ステートメントを非同期タスクとして送信します。

このステートメントを使用して以下を行うことができます:

  • バックグラウンドで長時間実行されるタスクを実行する (v2.5 以降でサポート)
  • 定期的にタスクをスケジュールする (v3.3 以降でサポート)

サポートされているステートメントには以下が含まれます:

タスクの一覧は INFORMATION_SCHEMA.tasks をクエリすることで確認でき、タスクの実行履歴は INFORMATION_SCHEMA.task_runs をクエリすることで確認できます。詳細については、使用上の注意を参照してください。

非同期タスクを削除するには DROP TASK を使用できます。

構文​

SUBMIT TASK <task_name> 
[SCHEDULE [START(<schedule_start>)] EVERY(INTERVAL <schedule_interval>) ]
[PROPERTIES(<"key" = "value"[, ...]>)]
AS <etl_statement>

PROPERTIES​

session. プレフィックスを持つセッション変数を追加することで、タスク実行時の接続コンテキスト設定を変更できます。

例えば、以下のステートメントは、クエリプロファイルを有効にし、クエリタイムアウトを増加させるセッションプロパティを持つ test_task という名前のタスクを送信します：

SUBMIT TASK test_task
PROPERTIES (
    "session.enable_profile" = "true",
    "session.insert_timeout" = "10000"
)
AS insert into t2 select * from t1;

パラメータ​

パラメータ必須説明
task_nameはいタスクの名前です。
schedule_startいいえスケジュールされたタスクの開始時間です。
schedule_intervalいいえスケジュールされたタスクが実行される間隔で、最小間隔は10秒です。
etl_statementはい非同期タスクとして送信したい ETL ステートメントです。StarRocks は現在、CREATE TABLE AS SELECT と INSERT の非同期タスクの送信をサポートしています。

使用上の注意​

このステートメントは、ETL ステートメントを実行するタスクを保存するテンプレートである Task を作成します。Task の情報は、メタデータビュー tasks in Information Schema をクエリすることで確認できます。

SELECT * FROM INFORMATION_SCHEMA.tasks;
SELECT * FROM information_schema.tasks WHERE task_name = '<task_name>';

Task を実行すると、それに応じて TaskRun が生成されます。TaskRun は、ETL ステートメントを実行するタスクを示します。TaskRun には以下の状態があります:

  • PENDING: タスクは実行待ちです。
  • RUNNING: タスクは実行中です。
  • FAILED: タスクは失敗しました。
  • SUCCESS: タスクは正常に実行されました。

TaskRun の状態は、メタデータビュー task_runs in Information Schema をクエリすることで確認できます。

SELECT * FROM INFORMATION_SCHEMA.task_runs;
SELECT * FROM information_schema.task_runs WHERE task_name = '<task_name>';

FE 設定項目による設定​

非同期 ETL タスクは、以下の FE 設定項目を使用して設定できます:

パラメータデフォルト値説明
task_ttl_second86400Task が有効である期間です。単位: 秒。有効期間を超えたタスクは削除されます。ここで、Task は一度だけ実行される非定期タスクを示します。
task_check_interval_second3600無効な Task を削除する時間間隔です。単位: 秒。
task_runs_ttl_second86400TaskRun が有効である期間です。単位: 秒。有効期間を超えた TaskRun は自動的に削除されます。さらに、FAILED および SUCCESS 状態の TaskRun も自動的に削除されます。TaskRun は定期タスクの個々の実行を示します。
task_runs_concurrency4並行して実行できる TaskRun の最大数です。
task_runs_queue_length500実行待ちの TaskRun の最大数です。デフォルト値を超えると、受信タスクは一時停止されます。
task_runs_max_history_number10000保持する TaskRun レコードの最大数です。
task_min_schedule_interval_s10Task 実行の最小間隔です。単位: 秒。

例​

例 1: CREATE TABLE tbl1 AS SELECT * FROM src_tbl の非同期タスクを送信し、タスク名を etl0 と指定します:

SUBMIT TASK etl0 AS CREATE TABLE tbl1 AS SELECT * FROM src_tbl;

例 2: INSERT INTO tbl2 SELECT * FROM src_tbl の非同期タスクを送信し、タスク名を etl1 と指定します:

SUBMIT TASK etl1 AS INSERT INTO tbl2 SELECT * FROM src_tbl;

例 3: INSERT OVERWRITE tbl3 SELECT * FROM src_tbl の非同期タスクを送信します:

SUBMIT TASK AS INSERT OVERWRITE tbl3 SELECT * FROM src_tbl;

例 4: タスク名を指定せずに INSERT OVERWRITE insert_wiki_edit SELECT * FROM source_wiki_edit の非同期タスクを送信し、ヒントを使用してクエリタイムアウトを 100000 秒に延長します:

SUBMIT /*+set_var(insert_timeout=100000)*/ TASK AS
INSERT OVERWRITE insert_wiki_edit
SELECT * FROM source_wiki_edit;

例 5: INSERT OVERWRITE ステートメントの非同期タスクを作成します。このタスクは 1 分間隔で定期的に実行されます。

SUBMIT TASK
SCHEDULE EVERY(INTERVAL 1 MINUTE)
AS
INSERT OVERWRITE insert_wiki_edit
    SELECT dt, user_id, count(*) 
    FROM source_wiki_edit 
    GROUP BY dt, user_id;

例 6: カスタムセッションプロパティを持つタスクを作成します:

SUBMIT TASK test_task
PROPERTIES (
    "session.enable_profile" = "true",
    "session.insert_timeout" = "10000"
)
AS insert into t2 select * from t1;