Spark Batch - Get Spark Batch Job
Hiermee haalt u één Spark-batchtaak op.
GET {endpoint}/livyApi/versions/{livyApiVersion}/sparkPools/{sparkPoolName}/batches/{batchId}
GET {endpoint}/livyApi/versions/{livyApiVersion}/sparkPools/{sparkPoolName}/batches/{batchId}?detailed={detailed}
URI-parameters
Name | In | Vereist | Type | Description |
---|---|---|---|---|
batch
|
path | True |
integer int32 |
Id voor de batchtaak. |
endpoint
|
path | True |
string |
Het eindpunt voor de ontwikkeling van de werkruimte, bijvoorbeeld |
livy
|
path | True |
string |
Geldige API-versie voor de aanvraag. |
spark
|
path | True |
string |
Naam van de Spark-pool. |
detailed
|
query |
boolean |
Optionele queryparameter die aangeeft of een gedetailleerd antwoord wordt geretourneerd buiten gewone livy. |
Antwoorden
Name | Type | Description |
---|---|---|
200 OK |
Geslaagd |
Voorbeelden
Gets a single spark batch job.
Voorbeeldaanvraag
GET myWorkspace.dev.azuresynapse.net/livyApi/versions/2020-12-01/sparkPools/mySparkPool/batches/123?detailed=True
Voorbeeldrespons
{
"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": []
}
Definities
Name | Description |
---|---|
Livy |
De batchstatus |
Plugin |
|
Scheduler |
|
Spark |
|
Spark |
Het resultaat van de Spark-batchtaak. |
Spark |
|
Spark |
|
Spark |
Het taaktype. |
Spark |
|
Spark |
|
Spark |
|
Spark |
LivyStates
De batchstatus
Name | Type | Description |
---|---|---|
busy |
string |
|
dead |
string |
|
error |
string |
|
idle |
string |
|
killed |
string |
|
not_started |
string |
|
recovering |
string |
|
running |
string |
|
shutting_down |
string |
|
starting |
string |
|
success |
string |
PluginCurrentState
Name | Type | Description |
---|---|---|
Cleanup |
string |
|
Ended |
string |
|
Monitoring |
string |
|
Preparation |
string |
|
Queued |
string |
|
ResourceAcquisition |
string |
|
Submission |
string |
SchedulerCurrentState
Name | Type | Description |
---|---|---|
Ended |
string |
|
Queued |
string |
|
Scheduled |
string |
SparkBatchJob
Name | Type | Description |
---|---|---|
appId |
string |
De toepassings-id van deze sessie |
appInfo |
object |
De gedetailleerde toepassingsgegevens. |
artifactId |
string |
De artefact-id. |
errorInfo |
De foutinformatie. |
|
id |
integer |
De sessie-id. |
jobType |
Het taaktype. |
|
livyInfo | ||
log |
string[] |
De logboekregels. |
name |
string |
De batchnaam. |
pluginInfo |
De informatie over de invoegtoepassing. |
|
result |
Het resultaat van de Spark-batchtaak. |
|
schedulerInfo |
De scheduler-informatie. |
|
sparkPoolName |
string |
De naam van de Spark-pool. |
state |
De batchstatus |
|
submitterId |
string |
De inzender-id. |
submitterName |
string |
De naam van de inzender. |
tags |
object |
De tags. |
workspaceName |
string |
De naam van de werkruimte. |
SparkBatchJobResultType
Het resultaat van de Spark-batchtaak.
Name | Type | Description |
---|---|---|
Cancelled |
string |
|
Failed |
string |
|
Succeeded |
string |
|
Uncertain |
string |
SparkBatchJobState
Name | Type | Description |
---|---|---|
currentState |
string |
de status van de Spark-taak. |
deadAt |
string |
tijd dat waarop "dode" livy staat voor het eerst werd gezien. |
jobCreationRequest | ||
killedAt |
string |
het tijdstip waarop de "vermoorde" livy-staat voor het eerst werd gezien. |
notStartedAt |
string |
het tijdstip waarop "not_started" livy voor het eerst werd gezien. |
recoveringAt |
string |
het tijdstip waarop de "herstellende" livy-status voor het eerst werd gezien. |
runningAt |
string |
het tijdstip waarop de "lopende" livy-status voor het eerst werd gezien. |
startingAt |
string |
het tijdstip waarop de "beginnende" livy-status voor het eerst werd gezien. |
successAt |
string |
het tijdstip waarop "succes" livy staat voor het eerst werd gezien. |
SparkErrorSource
Name | Type | Description |
---|---|---|
Dependency |
string |
|
System |
string |
|
Unknown |
string |
|
User |
string |
SparkJobType
Het taaktype.
Name | Type | Description |
---|---|---|
SparkBatch |
string |
|
SparkSession |
string |
SparkRequest
Name | Type | Description |
---|---|---|
archives |
string[] |
|
args |
string[] |
|
className |
string |
|
conf |
object |
|
driverCores |
integer |
|
driverMemory |
string |
|
executorCores |
integer |
|
executorMemory |
string |
|
file |
string |
|
files |
string[] |
|
jars |
string[] |
|
name |
string |
|
numExecutors |
integer |
|
pyFiles |
string[] |
SparkScheduler
Name | Type | Description |
---|---|---|
cancellationRequestedAt |
string |
|
currentState | ||
endedAt |
string |
|
scheduledAt |
string |
|
submittedAt |
string |
SparkServiceError
Name | Type | Description |
---|---|---|
errorCode |
string |
|
message |
string |
|
source |
SparkServicePlugin
Name | Type | Description |
---|---|---|
cleanupStartedAt |
string |
|
currentState | ||
monitoringStartedAt |
string |
|
preparationStartedAt |
string |
|
resourceAcquisitionStartedAt |
string |
|
submissionStartedAt |
string |