次の方法で共有


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 パラメーター

名前 / 必須 説明
batchId
path True

integer (int32)

バッチ ジョブの識別子。

endpoint
path True

string

ワークスペース開発エンドポイント (https://myworkspace.dev.azuresynapse.netなど)。

livyApiVersion
path True

string

要求の有効な API バージョン。

sparkPoolName
path True

string

Spark プールの名前。

detailed
query

boolean

プレーン livy を超えて詳細な応答が返されるかどうかを指定する省略可能なクエリ パラメーター。

応答

名前 説明
200 OK

SparkBatchJob

成功

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": []
}

定義

名前 説明
LivyStates

バッチ状態

PluginCurrentState
SchedulerCurrentState
SparkBatchJob
SparkBatchJobResultType

Spark バッチ ジョブの結果。

SparkBatchJobState
SparkErrorSource
SparkJobType

ジョブの種類。

SparkRequest
SparkScheduler
SparkServiceError
SparkServicePlugin

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

SparkServiceError[]

エラー情報。

id

integer (int32)

セッション ID。

jobType

SparkJobType

ジョブの種類。

livyInfo

SparkBatchJobState

log

string[]

ログ行。

name

string

バッチ名。

pluginInfo

SparkServicePlugin

プラグイン情報。

result

SparkBatchJobResultType

Spark バッチ ジョブの結果。

schedulerInfo

SparkScheduler

スケジューラ情報。

sparkPoolName

string

Spark プール名。

state

LivyStates

バッチ状態

submitterId

string

提出者識別子。

submitterName

string

提出者の名前。

tags

object

タグ。

workspaceName

string

ワークスペース名。

SparkBatchJobResultType

Spark バッチ ジョブの結果。

説明
Uncertain
Succeeded
Failed
Cancelled

SparkBatchJobState

名前 説明
currentState

string

Spark ジョブの状態。

deadAt

string (date-time)

「死んだ」生き生きとした状態が最初に見られた時間。

jobCreationRequest

SparkRequest

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

SchedulerCurrentState

endedAt

string (date-time)

scheduledAt

string (date-time)

submittedAt

string (date-time)

SparkServiceError

名前 説明
errorCode

string

message

string

source

SparkErrorSource

SparkServicePlugin

名前 説明
cleanupStartedAt

string (date-time)

currentState

PluginCurrentState

monitoringStartedAt

string (date-time)

preparationStartedAt

string (date-time)

resourceAcquisitionStartedAt

string (date-time)

submissionStartedAt

string (date-time)