Skip to content

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