Spark タスクのリストを照会します。
今すぐお試しください
テスト
RAM 認証
|
アクション |
アクセスレベル |
リソースタイプ |
条件キー |
依存アクション |
|
emr-serverless-spark:ListJobRuns |
list |
*すべてのリソース。
|
なし | なし |
リクエスト構文
GET /api/v1/workspaces/{workspaceId}/jobRuns HTTP/1.1パスパラメーター
|
パラメーター |
型 |
必須 / 任意 |
説明 |
例 |
| workspaceId |
string |
必須 |
ワークスペース ID。 |
w-d2d82aa09155**** |
リクエストパラメーター
|
パラメーター |
型 |
必須 / 任意 |
説明 |
例 |
| nextToken |
string |
任意 |
読み取りを開始する位置を示すページネーショントークン。 |
DD6B1B2A-5837-5237-ABE4-FF0C89568980 |
| maxResults |
integer |
任意 |
1 回のリクエストで取得するレコードの最大数。最大値: 100。 |
20 |
| name |
string |
任意 |
タスク名。 |
emr-spark-demo-job |
| creator |
string |
任意 |
タスクを作成したユーザーの UID。 |
150976534701**** |
| jobRunId |
string |
任意 |
タスク ID。 |
j-xxx |
| tags |
array<object> |
任意 |
タグのリスト。 |
|
|
object |
任意 |
タグオブジェクト。 |
||
| key |
string |
任意 |
タグキー。 |
tag_key |
| value |
string |
任意 |
タグ値。 |
value |
| states |
array |
任意 |
タスクステータス。 |
["Running","Submitted"] |
|
string |
任意 |
タスクステータス。有効な値:
|
Running |
|
| startTime |
object |
任意 |
タスクの開始時刻の有効値。 |
|
| startTime |
integer |
任意 |
開始時刻の有効値の開始時刻。 |
1709740800000 |
| endTime |
integer |
任意 |
開始時刻の有効値の終了時刻。 |
1710432000000 |
| endTime |
object |
任意 |
タスクの終了時間の有効値。 |
|
| startTime |
integer |
任意 |
終了時間の有効値の開始時刻。 |
1709740800000 |
| endTime |
integer |
任意 |
終了時間の有効値の終了時刻。 |
1710432000000 |
| resourceQueueId |
string |
任意 |
Spark タスクを実行するリソースキューの名前。 |
dev_queue |
| jobRunDeploymentId |
string |
任意 |
ストリーミングタスク Deployment のタスク ID。 |
jd-b6d003f1930f**** |
| regionId |
string |
任意 |
リージョン ID。 |
cn-hangzhou |
| minDuration |
integer |
任意 |
タスクの実行時間の最小値 (ミリ秒単位)。 |
60000 |
| isWorkflow |
string |
任意 |
タスクがワークフロータスクであるかどうかを指定します。 |
false |
| runtimeConfigs |
string |
任意 |
ランタイム構成。 |
[{\"key\":\"mainClass\",\"value\":\"yourClass\"}] |
| applicationConfigs |
string |
任意 |
Spark 構成。 |
[{\"key\":\"spark.app.name\",\"value\":\"test\"}] |
レスポンスフィールド
|
フィールド |
型 |
説明 |
例 |
|
object |
応答パラメーター。 |
||
| jobRuns |
array<object> |
Spark タスクのリスト。 |
|
|
array<object> |
Spark ノードタスクオブジェクト。 |
||
| workspaceId |
string |
ワークスペース ID。 |
w-d2d82aa09155**** |
| jobRunId |
string |
タスク ID。 |
jr-231231 |
| name |
string |
タスク名。 |
jobName |
| state |
string |
タスクステータス。 |
Running |
| stateChangeReason |
object |
ステータス変更の理由。 |
|
| code |
string |
エラーコード。 |
0 |
| message |
string |
エラーメッセージ。 |
connection refused |
| submitTime |
integer |
タスク送信時間。 |
1684119314000 |
| endTime |
integer |
タスク終了時間。 |
1684119314000 |
| codeType |
string |
タスクコードタイプ。有効な値: SQL JAR PYTHON。 |
SQL |
| webUI |
string |
タスク Web UI。 |
http://spark-ui |
| executionTimeoutSeconds |
integer |
実行タイムアウト期間 (秒単位)。 |
3600 |
| creator |
string |
タスクを作成したユーザーの UID。 |
150978934701**** |
| tags |
array |
タグ。 |
|
| Tag |
タスクタグ。 |
||
| log | RunLog |
実行ログのパス。 |
|
| releaseVersion |
string |
タスクの実行に使用された Spark DPI エンジンのバージョン。 |
esr-3.0.0 (Spark 3.4.3, Scala 2.12, Native Runtime) |
| jobDriver | JobDriver |
Spark ドライバー情報。このパラメーターは List 操作では返されません。 |
|
| configurationOverrides |
object |
Spark 詳細構成。このパラメーターは List 操作では返されません。 |
|
| configurations |
array |
Spark 構成のリスト。 |
|
| Configuration |
Spark 構成オブジェクト。 |
||
| displayReleaseVersion |
string |
タスクの実行に使用された Spark DPI エンジンのバージョン。 |
esr-3.0.0 (Spark 3.4.3, Scala 2.12) |
| fusion |
boolean |
Fusion エンジンアクセラレーションが有効かどうかを示します。 |
true |
| vcoreSeconds |
integer |
割り当てられた vcore の総数にタスクの実行中の秒数を掛けた値。 |
8236 |
| mbSeconds |
integer |
割り当てられたメモリの合計量にタスクの実行中の秒数を掛けた値。 |
33030784 |
| cuHours |
number |
タスク実行サイクル中に消費されたコンピューティングユニット (CU) の数。この値は推定値です。実際の値は請求書に基づきます。 |
2.059 |
| resourceQueueId |
string |
dev_queue |
|
| priority |
string |
5 |
|
| requestId |
string |
リクエスト ID。 |
DD6B1B2A-5837-5237-ABE4-FF0C8944**** |
| nextToken |
string |
データの読み取り位置。 |
1 |
| maxResults |
integer |
このリクエストで返されるレコードの最大値。 |
20 |
| totalCount |
integer |
リクエスト条件に一致するレコードの総数。 |
200 |
| aggregations |
object |
||
|
string |
例
成功レスポンス
JSONJSON
{
"jobRuns": [
{
"workspaceId": "w-d2d82aa09155****",
"jobRunId": "jr-231231",
"name": "jobName",
"state": "Running",
"stateChangeReason": {
"code": "0",
"message": "connection refused\n"
},
"submitTime": 1684119314000,
"endTime": 1684119314000,
"codeType": "SQL",
"webUI": "http://spark-ui",
"executionTimeoutSeconds": 3600,
"creator": "150978934701****",
"tags": [
{
"key": "workflowId",
"value": "wf-123test"
}
],
"log": {
"driverStdOut": "oss://bucket/path/to/stdout",
"driverStdError": "oss://bucket/path/to/stderr",
"driverSyslog": "oss://bucket/path/to/syslog",
"driverStartup": "oss://bucket/path/to/startup"
},
"releaseVersion": "esr-3.0.0 (Spark 3.4.3, Scala 2.12, Native Runtime)",
"jobDriver": {
"sparkSubmit": {
"entryPoint": "oss://bucket/path/to/entrypoint.jar",
"entryPointArguments": [
"arg1"
],
"sparkSubmitParameters": "--conf spark.app.name=test"
}
},
"configurationOverrides": {
"configurations": [
{
"configFileName": "common.conf",
"configItemKey": "hive.metastore.type",
"configItemValue": "USER_RDS"
}
]
},
"displayReleaseVersion": "esr-3.0.0 (Spark 3.4.3, Scala 2.12)",
"fusion": true,
"vcoreSeconds": 8236,
"mbSeconds": 33030784,
"cuHours": 2.059,
"resourceQueueId": "dev_queue",
"priority": "5"
}
],
"requestId": "DD6B1B2A-5837-5237-ABE4-FF0C8944****",
"nextToken": "1",
"maxResults": 20,
"totalCount": 200,
"aggregations": {
"key": ""
}
}エラーコード
完全なリストについては、「エラーコード」をご参照ください。
変更履歴
完全なリストについては、「変更履歴」をご参照ください。