SHOW ROUTINE LOAD
説明
Routine Load ジョブの実行情報を表示します。
You can manage Routine Load jobs that run on StarRocks tables only as a user who has the INSERT privilege on those StarRocks tables. If you do not have the INSERT privilege, follow the instructions provided in GRANT to grant the INSERT privilege to the user that you use to connect to your StarRocks cluster.
構文
SHOW [ALL] ROUTINE LOAD [ FOR [<db_name>.]<job_name> | FROM <db_name> ]
[ WHERE [ STATE = { "NEED_SCHEDULE" | "RUNNING" | "PAUSED" | "UNSTABLE" | "STOPPED" | "CANCELLED" } ] ]
[ ORDER BY field_name [ ASC | DESC ] ]
[ LIMIT { [offset, ] limit | limit OFFSET offset } ]
ヒント
通常の横向きのテーブル形式ではなく、返される結果を縦に表示するために、ステートメントに \G オプションを追加できます（例: SHOW ROUTINE LOAD FOR <job_name>\G）。
パラメータ
| パラメータ | 必須 | 説明 |
|---|---|---|
| db_name | いいえ | ロードジョブが属するデータベースの名前。このパラメータは FROM 句が使用される場合に必要です。 |
| job_name | いいえ | ロードジョブの名前。このパラメータは FOR 句が使用される場合に必要です。 |
| ALL | いいえ | STOPPED または CANCELLED 状態のものを含むすべてのロードジョブを表示します。 |
| STATE | いいえ | ロードジョブのステータス。 |
| ORDER BY field_name [ASC | DESC] | いいえ | 指定されたフィールドに基づいて返される結果を昇順または降順にソートします。サポートされるフィールドは次のとおりです: Id, Name, CreateTime, PauseTime, EndTime, TableName, State, および CurrentTaskNum。
Id の昇順にソートされます。 |
| LIMIT limit | いいえ | 返されるロードジョブの数。例えば、LIMIT 10 が指定されている場合、フィルター条件に一致するロードジョブの情報が10件のみ返されます。このパラメータが指定されていない場合、フィルター条件に一致するすべてのロードジョブの情報が表示されます。 |
| OFFSET offset | いいえ | offset パラメータはスキップされるロードジョブの数を定義します。例えば、OFFSET 5 は最初の5件のロードジョブをスキップし、残りを返します。offset パラメータの値はデフォルトで 0 です。 |
出力
| パラメータ | 説明 |
|---|---|
| Id | StarRocks によって自動生成されるロードジョブのグローバルに一意のID。 |
| Name | ロードジョブの名前。 |
| CreateTime | ロードジョブが作成された日時。 |
| PauseTime | ロードジョブが PAUSED 状態に入った日時。 |
| EndTime | ロードジョブが STOPPED 状態に入った日時。 |
| DbName | ロードジョブのターゲットテーブルが属するデータベース。 |
| TableName | ロードジョブのターゲットテーブル。 |
| State | ロードジョブのステータス。含まれる状態:
|
| DataSourceType | データソースのタイプ。固定値: KAFKA。 |
| CurrentTaskNum | ロードジョブ内の現在のタスク数。 |
| JobProperties | ロードジョブのプロパティ。消費されるパーティションやカラムマッピングなど。 |
| DataSourceProperties | データソースのプロパティ。トピックや Kafka クラスター内のブローカーのアドレスとポートのリストなど。 |
| CustomProperties | ロードジョブで定義された追加のデータソース関連プロパティ。 |
| Statistic | データロードの統計情報。成功した行数、総行数、受信データ量など。 |
| Progress | トピックのパーティション内のメッセージ消費の進捗（オフセットで測定）。 |
| TimestampProgress | トピックのパーティション内のメッセージ消費の進捗（タイムスタンプで測定）。 |
| ReasonOfStateChanged | ロードジョブが CANCELLED または PAUSED 状態にある理由。 |
| ErrorLogUrls | エラーログの URL。curl または wget コマンドを使用して URL にアクセスできます。 |
| TrackingSQL | information_schema データベースに記録されたエラーログ情報を直接クエリするための SQL コマンド。 |
| OtherMsg | Routine Load ジョブのすべての失敗したロードタスクに関する情報。 |
| LatestSourcePosition | トピックの各パーティション内の最新メッセージの位置。データロードの遅延を確認するのに役立ちます。 |
例
ロードジョブが正常に開始され、RUNNING 状態にある場合、返される結果は次のようになります:
MySQL [example_db]> SHOW ROUTINE LOAD FOR example_tbl_ordertest1\G
*************************** 1. row ***************************
Id: 10204
Name: example_tbl_ordertest1
CreateTime: 2023-12-21 21:01:31
PauseTime: NULL
EndTime: NULL
DbName: example_db
TableName: example_tbl
State: RUNNING
DataSourceType: KAFKA
CurrentTaskNum: 1
JobProperties: {"partitions":"*","rowDelimiter":"\t","partial_update":"false","columnToColumnExpr":"order_id,pay_dt,customer_name,nationality,temp_gender,price","maxBatchIntervalS":"10","partial_update_mode":"null","whereExpr":"*","timezone":"Asia/Shanghai","format":"csv","columnSeparator":"','","log_rejected_record_num":"0","taskTimeoutSecond":"60","json_root":"","maxFilterRatio":"1.0","strict_mode":"false","jsonpaths":"","taskConsumeSecond":"15","desireTaskConcurrentNum":"5","maxErrorNum":"0","strip_outer_array":"false","currentTaskConcurrentNum":"1","maxBatchRows":"200000"}
DataSourceProperties: {"topic":"lilyliuyitest4csv","currentKafkaPartitions":"0","brokerList":"xxx.xx.xx.xxx:9092"}
CustomProperties: {"kafka_default_offsets":"OFFSET_BEGINNING","group.id":"example_tbl_ordertest1_b05da08f-9b9d-4fe1-b1f2-25d7116d617c"}
Statistic: {"receivedBytes":313,"errorRows":0,"committedTaskNum":1,"loadedRows":6,"loadRowsRate":0,"abortedTaskNum":0,"totalRows":6,"unselectedRows":0,"receivedBytesRate":0,"taskExecuteTimeMs":699}
Progress: {"0":"5"}
TimestampProgress: {"0":"1686143856061"}
ReasonOfStateChanged:
ErrorLogUrls:
TrackingSQL:
OtherMsg:
LatestSourcePosition: {"0":"6"}
1 row in set (0.01 sec)
ロードジョブが例外により PAUSED または CANCELLED 状態にある場合、返される結果の ReasonOfStateChanged、ErrorLogUrls、TrackingSQL、および OtherMsg フィールドに基づいてトラブルシューティングを行うことができます。
MySQL [example_db]> SHOW ROUTINE LOAD FOR example_tbl_ordertest2\G
*************************** 1. row ***************************
Id: 10204
Name: example_tbl_ordertest2
CreateTime: 2023-12-22 12:13:18
PauseTime: 2023-12-22 12:13:38
EndTime: NULL
DbName: example_db
TableName: example_tbl
State: PAUSED
DataSourceType: KAFKA
CurrentTaskNum: 0
JobProperties: {"partitions":"*","rowDelimiter":"\t","partial_update":"false","columnToColumnExpr":"order_id,pay_dt,customer_name,nationality,temp_gender,price","maxBatchIntervalS":"10","partial_update_mode":"null","whereExpr":"*","timezone":"Asia/Shanghai","format":"csv","columnSeparator":"','","log_rejected_record_num":"0","taskTimeoutSecond":"60","json_root":"","maxFilterRatio":"1.0","strict_mode":"false","jsonpaths":"","taskConsumeSecond":"15","desireTaskConcurrentNum":"5","maxErrorNum":"0","strip_outer_array":"false","currentTaskConcurrentNum":"1","maxBatchRows":"200000"}
DataSourceProperties: {"topic":"mytest","currentKafkaPartitions":"0","brokerList":"xxx.xx.xx.xxx:9092"}
CustomProperties: {"kafka_default_offsets":"OFFSET_BEGINNING","group.id":"example_tbl_ordertest2_b3fada0f-6721-4ad1-920d-e4bf6d6ea7f7"}
Statistic: {"receivedBytes":541,"errorRows":10,"committedTaskNum":1,"loadedRows":6,"loadRowsRate":0,"abortedTaskNum":0,"totalRows":16,"unselectedRows":0,"receivedBytesRate":0,"taskExecuteTimeMs":646}
Progress: {"0":"19"}
TimestampProgress: {"0":"1702623900871"}
ReasonOfStateChanged: ErrorReason{errCode = 102, msg='current error rows is more than max error num'}
ErrorLogUrls: http://xxx.xx.xx.xxx:8040/api/_load_error_log?file=error_log_b25dcc7e642344b2_b0b342b9de0567db
TrackingSQL: select tracking_log from information_schema.load_tracking_logs where job_id=10204
OtherMsg:
LatestSourcePosition: {"0":"20"}
1 row in set (0.00 sec)