Skip to content

Creates and starts a new Spark Connect session on the specified cluster

Description

Creates and starts a new Spark Connect session on the specified cluster. The cluster must be in the RUNNING or WAITING state and have sessions enabled. This operation is supported in Amazon EMR Spark 8.0.0 and later.

Usage

emr_start_session(Name, ClusterId, ExecutionRoleArn,
  EngineConfigurations, MonitoringConfiguration,
  SessionIdleTimeoutInMinutes, ClientRequestToken, Tags)

Arguments

  • Name

An optional name for the session.

  • ClusterId

[required] The ID of the cluster on which to start the session.

  • ExecutionRoleArn

The execution role ARN for the session. Amazon EMR uses this role to access Amazon Web Services resources on your behalf during session execution.

  • EngineConfigurations

The configuration overrides for the session. Only runtime configuration overrides are supported.

  • MonitoringConfiguration

The monitoring configuration that controls where session logs are published, such as Amazon S3, CloudWatch, or managed logging.

  • SessionIdleTimeoutInMinutes

The idle timeout, in minutes. If the session is idle for this duration, Amazon EMR EC2 automatically terminates it.

  • ClientRequestToken

A unique, case-sensitive identifier that you provide to ensure the idempotency of the request. If you retry a request that completed successfully using the same client request token, the service returns the original response without performing the operation again.

  • Tags

The tags to assign to the session.

Value

A list with the following syntax:

list(
  Id = "string",
  ClusterId = "string",
  Arn = "string",
  AccountId = "string",
  State = "SUBMITTED"|"STARTING"|"STARTED"|"IDLE"|"BUSY"|"TERMINATING"|"TERMINATED"|"FAILED"
)

Request syntax

svc$start_session(
  Name = "string",
  ClusterId = "string",
  ExecutionRoleArn = "string",
  EngineConfigurations = list(
    list(
      Classification = "string",
      Configurations = list(),
      Properties = list(
        "string"
      )
    )
  ),
  MonitoringConfiguration = list(
    CloudWatchLoggingConfiguration = list(
      Enabled = TRUE|FALSE,
      LogGroup = "string",
      LogStreamNamePrefix = "string",
      EncryptionKeyArn = "string",
      LogTypes = list(
        list(
          "string"
        )
      )
    ),
    ManagedLoggingConfiguration = list(
      Enabled = TRUE|FALSE,
      EncryptionKeyArn = "string"
    ),
    S3LoggingConfiguration = list(
      Enabled = TRUE|FALSE,
      LogUri = "string",
      EncryptionKeyArn = "string",
      LogTypes = list(
        list(
          "string"
        )
      )
    )
  ),
  SessionIdleTimeoutInMinutes = 123,
  ClientRequestToken = "string",
  Tags = list(
    list(
      Key = "string",
      Value = "string"
    )
  )
)