diff --git a/ec2/spark_ec2.py b/ec2/spark_ec2.py index 6ce531e5054d8..52a89cb2481ca 100755 --- a/ec2/spark_ec2.py +++ b/ec2/spark_ec2.py @@ -200,6 +200,7 @@ def get_spark_shark_version(opts): sys.exit(1) return (version, spark_shark_map[version]) + # Attempt to resolve an appropriate AMI given the architecture and # region of the request. def get_spark_ami(opts): @@ -421,11 +422,11 @@ def launch_cluster(conn, opts, cluster_name): # Give the instances descriptive names for master in master_nodes: master.add_tag( - key='Name', + key='Name', value='spark-{cn}-master-{iid}'.format(cn=cluster_name, iid=master.id)) for slave in slave_nodes: slave.add_tag( - key='Name', + key='Name', value='spark-{cn}-slave-{iid}'.format(cn=cluster_name, iid=slave.id)) # Return all the instances