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