Skip to content

Commit 24a7c79

Browse files
committed
allow user to login into a cluster without slaves
1 parent 3a8b698 commit 24a7c79

File tree

1 file changed

+1
-3
lines changed

1 file changed

+1
-3
lines changed

ec2/spark_ec2.py

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -398,13 +398,11 @@ def get_existing_cluster(conn, opts, cluster_name, die_on_error=True):
398398
if any((master_nodes, slave_nodes)):
399399
print ("Found %d master(s), %d slaves" %
400400
(len(master_nodes), len(slave_nodes)))
401-
if (master_nodes != [] and slave_nodes != []) or not die_on_error:
401+
if master_nodes != [] or not die_on_error:
402402
return (master_nodes, slave_nodes)
403403
else:
404404
if master_nodes == [] and slave_nodes != []:
405405
print "ERROR: Could not find master in group " + cluster_name + "-master"
406-
elif master_nodes != [] and slave_nodes == []:
407-
print "ERROR: Could not find slaves in group " + cluster_name + "-slaves"
408406
else:
409407
print "ERROR: Could not find any existing cluster"
410408
sys.exit(1)

0 commit comments

Comments
 (0)