Spark Batch - Get Spark Batch Job

Szolgáltatás:

Synapse

API-verzió:

2020-12-01

Egyetlen spark batch-feladatot kap.

GET {endpoint}/livyApi/versions/{livyApiVersion}/sparkPools/{sparkPoolName}/batches/{batchId}

Opcionális paraméterekkel:

GET {endpoint}/livyApi/versions/{livyApiVersion}/sparkPools/{sparkPoolName}/batches/{batchId}?detailed={detailed}

URI-paraméterek

Name	In	Kötelező	Típus	Description
batchId	path	True	integer (int32)	A kötegelt feladat azonosítója.
endpoint	path	True	string	A munkaterület fejlesztési végpontja, például https://myworkspace.dev.azuresynapse.net.
livyApiVersion	path	True	string	A kérelem érvényes API-verziója.
sparkPoolName	path	True	string	A spark-készlet neve.
detailed	query		boolean	Nem kötelező lekérdezési param, amely megadja, hogy a rendszer a részletes választ az egyszerű livián túl adja-e vissza.

Válaszok

Name	Típus	Description
200 OK	SparkBatchJob	Siker

Példák

Gets a single spark batch job.

Mintakérelem

HTTP

GET myWorkspace.dev.azuresynapse.net/livyApi/versions/2020-12-01/sparkPools/mySparkPool/batches/123?detailed=True

Mintaválasz

Állapotkód:

200

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

Definíciók

Name	Description
LivyStates	A köteg állapota
PluginCurrentState
SchedulerCurrentState
SparkBatchJob
SparkBatchJobResultType	A Spark-kötegelt feladat eredménye.
SparkBatchJobState
SparkErrorSource
SparkJobType	A feladat típusa.
SparkRequest
SparkScheduler
SparkServiceError
SparkServicePlugin

LivyStates

Enumerálás

A köteg állapota

Érték	Description
busy
dead
error
idle
killed
not_started
recovering
running
shutting_down
starting
success

PluginCurrentState

Enumerálás

Érték	Description
Cleanup
Ended
Monitoring
Preparation
Queued
ResourceAcquisition
Submission

SchedulerCurrentState

Enumerálás

Érték	Description
Ended
Queued
Scheduled

SparkBatchJob

Objektum

Name	Típus	Description
appId	string	A munkamenet alkalmazásazonosítója
appInfo	object	A részletes alkalmazásadatok.
artifactId	string	Az összetevő azonosítója.
errorInfo	SparkServiceError[]	A hibainformációk.
id	integer (int32)	A munkamenet azonosítója.
jobType	SparkJobType	A feladat típusa.
livyInfo	SparkBatchJobState
log	string[]	A naplósorok.
name	string	A köteg neve.
pluginInfo	SparkServicePlugin	A beépülő modul adatai.
result	SparkBatchJobResultType	A Spark-kötegelt feladat eredménye.
schedulerInfo	SparkScheduler	Az ütemező adatai.
sparkPoolName	string	A Spark-készlet neve.
state	LivyStates	A köteg állapota
submitterId	string	A beküldő azonosítója.
submitterName	string	A beküldő neve.
tags	object	A címkék.
workspaceName	string	A munkaterület neve.

SparkBatchJobResultType

Enumerálás

A Spark-kötegelt feladat eredménye.

Érték	Description
Cancelled
Failed
Succeeded
Uncertain

SparkBatchJobState

Objektum

Name	Típus	Description
currentState	string	a Spark-feladat állapota.
deadAt	string (date-time)	időpont, amikor a "halott" livy államot először látták.
jobCreationRequest	SparkRequest
killedAt	string (date-time)	az az idő, amikor a "megölt" livy államot először látták.
notStartedAt	string (date-time)	az az időpont, amikor a "not_started" livy állapotot először látták.
recoveringAt	string (date-time)	az az időpont, amikor a livy állapot "helyreállítását" először látták.
runningAt	string (date-time)	az az időpont, amikor a "futó" livy állapotot először látták.
startingAt	string (date-time)	az az időpont, amikor a "kezdő" livy állapotot először látták.
successAt	string (date-time)	az az idő, amikor a "siker" livy állapotot először látták.

SparkErrorSource

Enumerálás

Érték	Description
Dependency
System
Unknown
User

SparkJobType

Enumerálás

A feladat típusa.

Érték	Description
SparkBatch
SparkSession

SparkRequest

Objektum

Name	Típus	Description
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

Objektum

Name	Típus	Description
cancellationRequestedAt	string (date-time)
currentState	SchedulerCurrentState
endedAt	string (date-time)
scheduledAt	string (date-time)
submittedAt	string (date-time)

SparkServiceError

Objektum

Name	Típus	Description
errorCode	string
message	string
source	SparkErrorSource

SparkServicePlugin

Objektum

Name	Típus	Description
cleanupStartedAt	string (date-time)
currentState	PluginCurrentState
monitoringStartedAt	string (date-time)
preparationStartedAt	string (date-time)
resourceAcquisitionStartedAt	string (date-time)
submissionStartedAt	string (date-time)