Skip to content

Commit cd7222c

Browse files
committed
Merge pull request apache#938 from ilikerps/master
Fix issue with spark_ec2 seeing empty security groups
2 parents 2aff798 + f589ce7 commit cd7222c

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

ec2/spark_ec2.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -364,12 +364,12 @@ def get_existing_cluster(conn, opts, cluster_name, die_on_error=True):
364364
slave_nodes = []
365365
for res in reservations:
366366
active = [i for i in res.instances if is_active(i)]
367-
if len(active) > 0:
368-
group_names = [g.name for g in res.groups]
367+
for inst in active:
368+
group_names = [g.name for g in inst.groups]
369369
if group_names == [cluster_name + "-master"]:
370-
master_nodes += res.instances
370+
master_nodes.append(inst)
371371
elif group_names == [cluster_name + "-slaves"]:
372-
slave_nodes += res.instances
372+
slave_nodes.append(inst)
373373
if any((master_nodes, slave_nodes)):
374374
print ("Found %d master(s), %d slaves" %
375375
(len(master_nodes), len(slave_nodes)))

0 commit comments

Comments
 (0)