Spark Batch - Get Spark Batch Job
1 つの Spark バッチ ジョブを取得します。
GET {endpoint}/livyApi/versions/{livyApiVersion}/sparkPools/{sparkPoolName}/batches/{batchId}
GET {endpoint}/livyApi/versions/{livyApiVersion}/sparkPools/{sparkPoolName}/batches/{batchId}?detailed={detailed}
URI パラメーター
名前 | / | 必須 | 型 | 説明 |
---|---|---|---|---|
batch
|
path | True |
integer (int32) |
バッチ ジョブの識別子。 |
endpoint
|
path | True |
string |
ワークスペース開発エンドポイント ( |
livy
|
path | True |
string |
要求の有効な API バージョン。 |
spark
|
path | True |
string |
Spark プールの名前。 |
detailed
|
query |
boolean |
プレーン livy を超えて詳細な応答が返されるかどうかを指定する省略可能なクエリ パラメーター。 |
応答
名前 | 型 | 説明 |
---|---|---|
200 OK |
成功 |
例
Gets a single spark batch job.
要求のサンプル
GET myWorkspace.dev.azuresynapse.net/livyApi/versions/2020-12-01/sparkPools/mySparkPool/batches/123?detailed=True
応答のサンプル
{
"livyInfo": null,
"name": "jobname",
"workspaceName": "myWorkspace",
"sparkPoolName": "mySparkPool",
"submitterName": "thetime",
"submitterId": "thesubmitterid",
"artifactId": "fill in here",
"jobType": "SparkBatch",
"result": "Failed",
"schedulerInfo": null,
"pluginInfo": null,
"errorInfo": [],
"tags": null,
"id": 1,
"appId": "fill in here",
"appInfo": null,
"state": "the state",
"log": []
}
定義
名前 | 説明 |
---|---|
Livy |
バッチ状態 |
Plugin |
|
Scheduler |
|
Spark |
|
Spark |
Spark バッチ ジョブの結果。 |
Spark |
|
Spark |
|
Spark |
ジョブの種類。 |
Spark |
|
Spark |
|
Spark |
|
Spark |
LivyStates
バッチ状態
値 | 説明 |
---|---|
not_started | |
starting | |
idle | |
busy | |
shutting_down | |
error | |
dead | |
killed | |
success | |
running | |
recovering |
PluginCurrentState
値 | 説明 |
---|---|
Preparation | |
ResourceAcquisition | |
Queued | |
Submission | |
Monitoring | |
Cleanup | |
Ended |
SchedulerCurrentState
値 | 説明 |
---|---|
Queued | |
Scheduled | |
Ended |
SparkBatchJob
名前 | 型 | 説明 |
---|---|---|
appId |
string |
このセッションのアプリケーション ID |
appInfo |
object |
詳細なアプリケーション情報。 |
artifactId |
string |
成果物識別子。 |
errorInfo |
エラー情報。 |
|
id |
integer (int32) |
セッション ID。 |
jobType |
ジョブの種類。 |
|
livyInfo | ||
log |
string[] |
ログ行。 |
name |
string |
バッチ名。 |
pluginInfo |
プラグイン情報。 |
|
result |
Spark バッチ ジョブの結果。 |
|
schedulerInfo |
スケジューラ情報。 |
|
sparkPoolName |
string |
Spark プール名。 |
state |
バッチ状態 |
|
submitterId |
string |
提出者識別子。 |
submitterName |
string |
提出者の名前。 |
tags |
object |
タグ。 |
workspaceName |
string |
ワークスペース名。 |
SparkBatchJobResultType
Spark バッチ ジョブの結果。
値 | 説明 |
---|---|
Uncertain | |
Succeeded | |
Failed | |
Cancelled |
SparkBatchJobState
名前 | 型 | 説明 |
---|---|---|
currentState |
string |
Spark ジョブの状態。 |
deadAt |
string (date-time) |
「死んだ」生き生きとした状態が最初に見られた時間。 |
jobCreationRequest | ||
killedAt |
string (date-time) |
「殺された」生き生きとした状態が最初に見られた時間。 |
notStartedAt |
string (date-time) |
"not_started" livy 状態が最初に見られた時刻。 |
recoveringAt |
string (date-time) |
リビ状態の "回復" が最初に見られた時刻。 |
runningAt |
string (date-time) |
"実行中" の livy 状態が最初に見られた時刻。 |
startingAt |
string (date-time) |
"開始" livy 状態が最初に見られた時刻。 |
successAt |
string (date-time) |
"成功" livy 状態が最初に見られた時刻。 |
SparkErrorSource
値 | 説明 |
---|---|
System | |
User | |
Unknown | |
Dependency |
SparkJobType
ジョブの種類。
値 | 説明 |
---|---|
SparkBatch | |
SparkSession |
SparkRequest
名前 | 型 | 説明 |
---|---|---|
archives |
string[] |
|
args |
string[] |
|
className |
string |
|
conf |
object |
|
driverCores |
integer (int32) |
|
driverMemory |
string |
|
executorCores |
integer (int32) |
|
executorMemory |
string |
|
file |
string |
|
files |
string[] |
|
jars |
string[] |
|
name |
string |
|
numExecutors |
integer (int32) |
|
pyFiles |
string[] |
SparkScheduler
名前 | 型 | 説明 |
---|---|---|
cancellationRequestedAt |
string (date-time) |
|
currentState | ||
endedAt |
string (date-time) |
|
scheduledAt |
string (date-time) |
|
submittedAt |
string (date-time) |
SparkServiceError
名前 | 型 | 説明 |
---|---|---|
errorCode |
string |
|
message |
string |
|
source |
SparkServicePlugin
名前 | 型 | 説明 |
---|---|---|
cleanupStartedAt |
string (date-time) |
|
currentState | ||
monitoringStartedAt |
string (date-time) |
|
preparationStartedAt |
string (date-time) |
|
resourceAcquisitionStartedAt |
string (date-time) |
|
submissionStartedAt |
string (date-time) |