Start Job Run

emrcontainers_start_job_run

R Documentation

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¶

name: The 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.
executionRoleArn: The execution role ARN for the job run.
releaseLabel: The Amazon EMR release version to use for the job run.
jobDriver: The job driver for the job run.
configurationOverrides: The configuration overrides for the job run.
tags: The tags assigned to job runs.
jobTemplateId: The job template ID to be used to start the job run.
jobTemplateParameters: The values of job template parameters to start a job run.
retryPolicyConfiguration: The retry policy configuration for the job run.

Value¶

A list with the following syntax:

list(
  id = "string",
  name = "string",
  arn = "string",
  virtualClusterId = "string"
)

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(
      persistentAppUI = "ENABLED"|"DISABLED",
      cloudWatchMonitoringConfiguration = list(
        logGroupName = "string",
        logStreamNamePrefix = "string"
      ),
      s3MonitoringConfiguration = list(
        logUri = "string"
      ),
      containerLogRotationConfiguration = list(
        rotationSize = "string",
        maxFilesToKeep = 123
      )
    )
  ),
  tags = list(
    "string"
  ),
  jobTemplateId = "string",
  jobTemplateParameters = list(
    "string"
  ),
  retryPolicyConfiguration = list(
    maxAttempts = 123
  )
)