Skip to content

Commit 3923f36

Browse files
committed
Update spark_ec2.py
Please, feel free to change the wording for --region, if required.
1 parent 4ecd9f9 commit 3923f36

File tree

1 file changed

+2
-3
lines changed

1 file changed

+2
-3
lines changed

ec2/spark_ec2.py

Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -132,7 +132,7 @@ def parse_args():
132132
help="Master instance type (leave empty for same as instance-type)")
133133
parser.add_option(
134134
"-r", "--region", default="us-east-1",
135-
help="EC2 region zone to launch instances in")
135+
help="EC2 region used to to launch instances in, or to find them in")
136136
parser.add_option(
137137
"-z", "--zone", default="",
138138
help="Availability zone to launch instances in, or 'all' to spread " +
@@ -608,8 +608,7 @@ def get_existing_cluster(conn, opts, cluster_name, die_on_error=True):
608608
elif (cluster_name + "-slaves") in group_names:
609609
slave_nodes.append(inst)
610610
if any((master_nodes, slave_nodes)):
611-
print "Found %d master(s), %d slaves" % (len(master_nodes), len(slave_nodes)) \
612-
+ " in region " + opts.region
611+
print "Found %d master(s), %d slaves" % (len(master_nodes), len(slave_nodes))
613612
if master_nodes != [] or not die_on_error:
614613
return (master_nodes, slave_nodes)
615614
else:

0 commit comments

Comments
 (0)