Skip to content

Start Job Run

emrserverless_start_job_run R Documentation

Starts a job run

Description

Starts a job run.

Usage

emrserverless_start_job_run(applicationId, clientToken,
  executionRoleArn, jobDriver, configurationOverrides, tags,
  executionTimeoutMinutes, name, mode, retryPolicy)

Arguments

applicationId

[required] The ID of the application on which to run the job.

clientToken

[required] The client idempotency token of the job run to start. Its value must be unique for each request.

executionRoleArn

[required] The execution role ARN 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 the job run.

executionTimeoutMinutes

The maximum duration for the job run to run. If the job run runs beyond this duration, it will be automatically cancelled.

name

The optional job run name. This doesn't have to be unique.

mode

The mode of the job run when it starts.

retryPolicy

The retry policy when job run starts.

Value

A list with the following syntax: 

list(
  applicationId = "string",
  jobRunId = "string",
  arn = "string"
)

Request syntax

svc$start_job_run(
  applicationId = "string",
  clientToken = "string",
  executionRoleArn = "string",
  jobDriver = list(
    sparkSubmit = list(
      entryPoint = "string",
      entryPointArguments = list(
        "string"
      ),
      sparkSubmitParameters = "string"
    ),
    hive = list(
      query = "string",
      initQueryFile = "string",
      parameters = "string"
    )
  ),
  configurationOverrides = list(
    applicationConfiguration = list(
      list(
        classification = "string",
        properties = list(
          "string"
        ),
        configurations = list()
      )
    ),
    monitoringConfiguration = list(
      s3MonitoringConfiguration = list(
        logUri = "string",
        encryptionKeyArn = "string"
      ),
      managedPersistenceMonitoringConfiguration = list(
        enabled = TRUE|FALSE,
        encryptionKeyArn = "string"
      ),
      cloudWatchLoggingConfiguration = list(
        enabled = TRUE|FALSE,
        logGroupName = "string",
        logStreamNamePrefix = "string",
        encryptionKeyArn = "string",
        logTypes = list(
          list(
            "string"
          )
        )
      ),
      prometheusMonitoringConfiguration = list(
        remoteWriteUrl = "string"
      )
    )
  ),
  tags = list(
    "string"
  ),
  executionTimeoutMinutes = 123,
  name = "string",
  mode = "BATCH"|"STREAMING",
  retryPolicy = list(
    maxAttempts = 123,
    maxFailedAttemptsPerHour = 123
  )
)