Skip to content

Starts a job run

Description

Starts a job run.

Usage

emrserverless_start_job_run(applicationId, clientToken,
  executionRoleArn, executionIamPolicy, 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.

  • executionIamPolicy

    You can pass an optional IAM policy. The resulting job IAM role permissions will be an intersection of this policy and the policy associated with your job execution role.

  • 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",
  executionIamPolicy = list(
    policy = "string",
    policyArns = list(
      "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"
      )
    ),
    diskEncryptionConfiguration = list(
      encryptionContext = list(
        "string"
      ),
      encryptionKeyArn = "string"
    )
  ),
  tags = list(
    "string"
  ),
  executionTimeoutMinutes = 123,
  name = "string",
  mode = "BATCH"|"STREAMING",
  retryPolicy = list(
    maxAttempts = 123,
    maxFailedAttemptsPerHour = 123
  )
)