Starts a job run¶
Description¶
Starts a job run. A job run is a unit of work, such as a Spark jar, PySpark script, or SparkSQL query, that you submit to Amazon EMR on EKS.
Usage¶
emrcontainers_start_job_run(name, virtualClusterId, clientToken,
executionRoleArn, releaseLabel, jobDriver, configurationOverrides, tags,
jobTemplateId, jobTemplateParameters, retryPolicyConfiguration)
Arguments¶
-
nameThe name of the job run.
-
virtualClusterId[required] The virtual cluster ID for which the job run request is submitted.
-
clientToken[required] The client idempotency token of the job run request.
-
executionRoleArnThe execution role ARN for the job run.
-
releaseLabelThe Amazon EMR release version to use for the job run.
-
jobDriverThe job driver for the job run.
-
configurationOverridesThe configuration overrides for the job run.
-
tagsThe tags assigned to job runs.
-
jobTemplateIdThe job template ID to be used to start the job run.
-
jobTemplateParametersThe values of job template parameters to start a job run.
-
retryPolicyConfigurationThe retry policy configuration for the job run.
Value¶
A list with the following syntax:
Request syntax¶
svc$start_job_run(
name = "string",
virtualClusterId = "string",
clientToken = "string",
executionRoleArn = "string",
releaseLabel = "string",
jobDriver = list(
sparkSubmitJobDriver = list(
entryPoint = "string",
entryPointArguments = list(
"string"
),
sparkSubmitParameters = "string"
),
sparkSqlJobDriver = list(
entryPoint = "string",
sparkSqlParameters = "string"
)
),
configurationOverrides = list(
applicationConfiguration = list(
list(
classification = "string",
properties = list(
"string"
),
configurations = list()
)
),
monitoringConfiguration = list(
managedLogs = list(
allowAWSToRetainLogs = "ENABLED"|"DISABLED",
encryptionKeyArn = "string"
),
persistentAppUI = "ENABLED"|"DISABLED",
cloudWatchMonitoringConfiguration = list(
logGroupName = "string",
logStreamNamePrefix = "string"
),
s3MonitoringConfiguration = list(
logUri = "string",
encryptionKeyArn = "string"
),
containerLogRotationConfiguration = list(
rotationSize = "string",
maxFilesToKeep = 123
)
)
),
tags = list(
"string"
),
jobTemplateId = "string",
jobTemplateParameters = list(
"string"
),
retryPolicyConfiguration = list(
maxAttempts = 123
)
)