Skip to content

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
  )
)