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