ListJobRuns 操作を呼び出して、Spark ジョブのリストを取得します。
今すぐお試しください
テスト
RAM 認証
|
アクション |
アクセスレベル |
リソースタイプ |
条件キー |
依存アクション |
|
emr-serverless-spark:ListJobRuns |
list |
*All Resource
|
なし | なし |
リクエスト構文
GET /api/v1/workspaces/{workspaceId}/jobRuns HTTP/1.1パスパラメーター
|
パラメーター |
型 |
必須 / 任意 |
説明 |
例 |
| workspaceId |
string |
必須 |
ワークスペース ID。 |
w-d2d82aa09155**** |
リクエストパラメーター
|
パラメーター |
型 |
必須 / 任意 |
説明 |
例 |
| nextToken |
string |
任意 |
次の読み取りを開始する位置を指定するトークン。 |
DD6B1B2A-5837-5237-ABE4-FF0C89568980 |
| maxResults |
integer |
任意 |
返すエントリの最大数。最大値は 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 ジョブが実行されるリソースキューの ID。 |
dev_queue |
| jobRunDeploymentId |
string |
任意 |
ストリーミングジョブのデプロイメント 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 エンジンのバージョン。 |
esr-3.0.0 (Spark 3.4.3, Scala 2.12, Native Runtime) |
| jobDriver | JobDriver |
Spark ドライバーに関する情報。このパラメーターは ListJobRuns 操作では返されません。 |
|
| configurationOverrides |
object |
高度な Spark 構成。このパラメーターは ListJobRuns 操作では返されません。 |
|
| configurations |
array |
Spark 構成のリスト。 |
|
| Configuration |
Spark 構成オブジェクト。 |
||
| displayReleaseVersion |
string |
ジョブの実行に使用される Spark エンジンの表示バージョン。 |
esr-3.0.0 (Spark 3.4.3, Scala 2.12) |
| fusion |
boolean |
Fusion エンジンがアクセラレーションのために有効になっているかどうかを示します。 |
true |
| vcoreSeconds |
integer |
ジョブ実行に割り当てられた vCore の総数に、ランタイム (秒単位) を乗算した値。 |
8236 |
| mbSeconds |
integer |
ジョブ実行に割り当てられた合計メモリ (MB) に、ランタイム (秒単位) を乗算した値。 |
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 |
例
成功レスポンス
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
}エラーコード
完全なリストについては、「エラーコード」をご参照ください。
変更履歴
完全なリストについては、「変更履歴」をご参照ください。