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(
      managedLogs = list(
        allowAWSToRetainLogs = "ENABLED"|"DISABLED",
        encryptionKeyArn = "string"
      ),
      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
  )
)