awsflow-emr

name	awsflow-emr
description	Manage and inspect AWS EMR clusters, steps, instances, studios, notebook executions, release labels, security configurations, and managed scaling using awsflow. Supports full lifecycle operations.

Awsflow EMR

Manage and inspect EMR clusters, steps, studios, notebook executions, and related configurations.

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
• Wants to launch or terminate clusters
• Needs to add steps, instance groups, or tags
• Wants to modify cluster settings or scaling policies

Tool: EMRTool

Describe and manage 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

Lifecycle and Management Commands

RunJobFlow

Create a new EMR cluster.

{ "command": "RunJobFlow", "params": { "Name": "analytics-cluster", "ReleaseLabel": "emr-7.0.0", "Instances": { "InstanceGroups": [{ "InstanceRole": "MASTER", "InstanceType": "m5.xlarge", "InstanceCount": 1 }] }, "ServiceRole": "EMR_DefaultRole", "JobFlowRole": "EMR_EC2_DefaultRole" } }

AddJobFlowSteps

Add steps to a cluster.

{ "command": "AddJobFlowSteps", "params": { "JobFlowId": "j-1234567890ABC", "Steps": [{ "Name": "spark-step", "ActionOnFailure": "CONTINUE", "HadoopJarStep": { "Jar": "command-runner.jar", "Args": ["spark-submit", "--deploy-mode", "cluster", "s3://bucket/job.py"] } }] } }

ModifyCluster

Modify cluster settings.

{ "command": "ModifyCluster", "params": { "ClusterId": "j-1234567890ABC", "StepConcurrencyLevel": 2 } }

PutAutoScalingPolicy

Configure auto scaling for an instance group.

{ "command": "PutAutoScalingPolicy", "params": { "ClusterId": "j-1234567890ABC", "InstanceGroupId": "ig-ABC123", "AutoScalingPolicy": { "Constraints": { "MinCapacity": 2, "MaxCapacity": 10 }, "Rules": [] } } }

AddTags

Tag a cluster.

{ "command": "AddTags", "params": { "ResourceId": "j-1234567890ABC", "Tags": { "env": "prod" } } }

RemoveTags

Remove tags from a cluster.

{ "command": "RemoveTags", "params": { "ResourceId": "j-1234567890ABC", "TagKeys": ["env"] } }

TerminateJobFlows

Terminate one or more clusters.

{ "command": "TerminateJobFlows", "params": { "JobFlowIds": ["j-1234567890ABC"] } }

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 S3Tool to inspect data
• EMR → EC2: Clusters run on EC2 instances. Use EC2Tool to inspect the underlying instances
• EMR → CloudWatch: Cluster metrics and logs in CloudWatch. Use CloudWatchLogTool to read logs
• EMR → IAM: Clusters use EC2 instance profiles and service roles. Use IAMTool to inspect
• EMR → Glue Data Catalog: EMR can use Glue Data Catalog as Hive metastore. Use GlueTool to query the catalog
• EMR → CloudFormation: EMR clusters managed by CloudFormation stacks