Awsflow EMR
Inspect EMR clusters, steps, studios, notebook executions, and related configurations. All commands are read-only.
When to Use This Skill
Use this skill when the user:
- •Asks about EMR clusters, Hadoop, or Spark
- •Wants to inspect cluster status, steps, or instances
- •Needs to view EMR studios or notebook executions
- •Asks about release labels, instance types, or security configurations
- •Wants to check auto-termination, managed scaling, or session credentials
Tool: EMRTool
Describe and list EMR clusters, steps, studios, and configurations. ALWAYS provide params object.
Commands
ListClusters
List EMR clusters with optional state filter.
{ "command": "ListClusters", "params": { "ClusterStates": ["RUNNING", "WAITING"] } }
Parameters:
| Parameter | Type | Required | Description |
|---|---|---|---|
| ClusterStates | array of strings | No | Filter by states: STARTING, BOOTSTRAPPING, RUNNING, WAITING, TERMINATING, TERMINATED, TERMINATED_WITH_ERRORS |
| CreatedAfter | string | No | ISO date string filter |
| CreatedBefore | string | No | ISO date string filter |
| Marker | string | No | Pagination marker |
DescribeCluster
Get detailed information about a cluster.
{ "command": "DescribeCluster", "params": { "ClusterId": "j-1234567890ABC" } }
Parameters:
| Parameter | Type | Required | Description |
|---|---|---|---|
| ClusterId | string | Yes | EMR cluster ID |
ListSteps
List steps in a cluster.
{ "command": "ListSteps", "params": { "ClusterId": "j-1234567890ABC", "StepStates": ["FAILED"] } }
Parameters:
| Parameter | Type | Required | Description |
|---|---|---|---|
| ClusterId | string | Yes | EMR cluster ID |
| StepStates | array of strings | No | Filter by step states |
| Marker | string | No | Pagination marker |
DescribeStep
Get details of a specific step.
{ "command": "DescribeStep", "params": { "ClusterId": "j-1234567890ABC", "StepId": "s-ABC123" } }
Parameters:
| Parameter | Type | Required | Description |
|---|---|---|---|
| ClusterId | string | Yes | EMR cluster ID |
| StepId | string | Yes | Step ID |
ListInstances
List EC2 instances in a cluster.
{ "command": "ListInstances", "params": { "ClusterId": "j-1234567890ABC", "InstanceStates": ["RUNNING"] } }
Parameters:
| Parameter | Type | Required | Description |
|---|---|---|---|
| ClusterId | string | Yes | EMR cluster ID |
| InstanceFleetId | string | No | Instance fleet ID filter |
| InstanceGroupId | string | No | Instance group ID filter |
| InstanceStates | array of strings | No | Filter by states |
ListInstanceFleets
List instance fleets in a cluster.
{ "command": "ListInstanceFleets", "params": { "ClusterId": "j-1234567890ABC" } }
Parameters:
| Parameter | Type | Required | Description |
|---|---|---|---|
| ClusterId | string | Yes | EMR cluster ID |
| Marker | string | No | Pagination marker |
ListInstanceGroups
List instance groups in a cluster.
{ "command": "ListInstanceGroups", "params": { "ClusterId": "j-1234567890ABC" } }
Parameters:
| Parameter | Type | Required | Description |
|---|---|---|---|
| ClusterId | string | Yes | EMR cluster ID |
| Marker | string | No | Pagination marker |
ListBootstrapActions
List bootstrap actions for a cluster.
{ "command": "ListBootstrapActions", "params": { "ClusterId": "j-1234567890ABC" } }
Parameters:
| Parameter | Type | Required | Description |
|---|---|---|---|
| ClusterId | string | Yes | EMR cluster ID |
| Marker | string | No | Pagination marker |
ListStudios
List EMR studios.
{ "command": "ListStudios", "params": {} }
Parameters:
| Parameter | Type | Required | Description |
|---|---|---|---|
| Marker | string | No | Pagination marker |
DescribeStudio
Get details of an EMR studio.
{ "command": "DescribeStudio", "params": { "StudioId": "es-ABC123" } }
Parameters:
| Parameter | Type | Required | Description |
|---|---|---|---|
| StudioId | string | Yes | Studio ID |
ListNotebookExecutions
List notebook executions.
{ "command": "ListNotebookExecutions", "params": {} }
Parameters:
| Parameter | Type | Required | Description |
|---|---|---|---|
| CreatedAfter | string | No | ISO date filter |
| CreatedBefore | string | No | ISO date filter |
| NextToken | string | No | Pagination token |
DescribeNotebookExecution
Get details of a notebook execution.
{ "command": "DescribeNotebookExecution", "params": { "NotebookExecutionId": "ex-ABC123" } }
Parameters:
| Parameter | Type | Required | Description |
|---|---|---|---|
| NotebookExecutionId | string | Yes | Notebook execution ID |
ListReleaseLabels
List available EMR release labels.
{ "command": "ListReleaseLabels", "params": {} }
Parameters:
| Parameter | Type | Required | Description |
|---|---|---|---|
| NextToken | string | No | Pagination token |
| MaxResults | number | No | Maximum results |
DescribeReleaseLabel
Get details for a release label.
{ "command": "DescribeReleaseLabel", "params": { "ReleaseLabel": "emr-7.0.0" } }
Parameters:
| Parameter | Type | Required | Description |
|---|---|---|---|
| ReleaseLabel | string | Yes | Release label |
ListSupportedInstanceTypes
List instance types supported for a release.
{ "command": "ListSupportedInstanceTypes", "params": { "ReleaseLabel": "emr-7.0.0" } }
Parameters:
| Parameter | Type | Required | Description |
|---|---|---|---|
| ReleaseLabel | string | No | Release label |
DescribeSecurityConfiguration
Get a security configuration.
{ "command": "DescribeSecurityConfiguration", "params": { "SecurityConfigurationName": "my-config" } }
Parameters:
| Parameter | Type | Required | Description |
|---|---|---|---|
| SecurityConfigurationName | string | Yes | Security configuration name |
ListSecurityConfigurations
List security configurations.
{ "command": "ListSecurityConfigurations", "params": {} }
Parameters:
| Parameter | Type | Required | Description |
|---|---|---|---|
| Marker | string | No | Pagination marker |
GetAutoTerminationPolicy
Get auto-termination policy for a cluster.
{ "command": "GetAutoTerminationPolicy", "params": { "ClusterId": "j-1234567890ABC" } }
Parameters:
| Parameter | Type | Required | Description |
|---|---|---|---|
| ClusterId | string | Yes | EMR cluster ID |
GetBlockPublicAccessConfiguration
Get block public access configuration.
{ "command": "GetBlockPublicAccessConfiguration", "params": {} }
GetManagedScalingPolicy
Get managed scaling policy for a cluster.
{ "command": "GetManagedScalingPolicy", "params": { "ClusterId": "j-1234567890ABC" } }
Parameters:
| Parameter | Type | Required | Description |
|---|---|---|---|
| ClusterId | string | Yes | EMR cluster ID |
GetClusterSessionCredentials
Get session credentials for a cluster.
{ "command": "GetClusterSessionCredentials", "params": { "ClusterId": "j-1234567890ABC", "CredentialType": "UsernamePassword" } }
Parameters:
| Parameter | Type | Required | Description |
|---|---|---|---|
| ClusterId | string | Yes | EMR cluster ID |
| CredentialType | string | Yes | Credential type |
| ExecutionRoleArn | string | No | Execution role ARN |
| DurationSeconds | number | No | Lifetime in seconds |
GetStudioSessionMapping
Get studio session mapping.
{ "command": "GetStudioSessionMapping", "params": { "StudioId": "es-ABC123", "IdentityType": "USER", "IdentityId": "user-123" } }
Parameters:
| Parameter | Type | Required | Description |
|---|---|---|---|
| StudioId | string | Yes | Studio ID |
| IdentityType | string | Yes | USER or GROUP |
| IdentityId | string | Yes | Identity ID |
ListStudioSessionMappings
List studio session mappings.
{ "command": "ListStudioSessionMappings", "params": { "StudioId": "es-ABC123" } }
Parameters:
| Parameter | Type | Required | Description |
|---|---|---|---|
| StudioId | string | Yes | Studio ID |
| IdentityType | string | No | USER or GROUP |
DescribeJobFlows
Describe job flows (legacy).
{ "command": "DescribeJobFlows", "params": { "JobFlowIds": ["j-ABC123"] } }
Parameters:
| Parameter | Type | Required | Description |
|---|---|---|---|
| JobFlowIds | array of strings | No | Job flow IDs |
| CreatedAfter | string | No | ISO date filter |
| CreatedBefore | string | No | ISO date filter |
DescribePersistentAppUI / GetOnClusterAppUIPresignedURL / GetPersistentAppUIPresignedURL
Application UI commands for Spark History Server, etc.
{ "command": "GetOnClusterAppUIPresignedURL", "params": { "ClusterId": "j-ABC123", "ApplicationId": "app-123" } }
Parameters:
| Parameter | Type | Required | Description |
|---|---|---|---|
| ClusterId | string | Yes | EMR cluster ID |
| ApplicationId | string | Yes | Application ID |
Related Services
- •EMR → S3: Clusters use S3 for input/output data (EMRFS), logs, and scripts. Use
S3Toolto inspect data - •EMR → EC2: Clusters run on EC2 instances. Use
EC2Toolto inspect the underlying instances - •EMR → CloudWatch: Cluster metrics and logs in CloudWatch. Use
CloudWatchLogToolto read logs - •EMR → IAM: Clusters use EC2 instance profiles and service roles. Use
IAMToolto inspect - •EMR → Glue Data Catalog: EMR can use Glue Data Catalog as Hive metastore. Use
GlueToolto query the catalog - •EMR → CloudFormation: EMR clusters managed by CloudFormation stacks