diff --git a/ec2/spark_ec2.py b/ec2/spark_ec2.py index 5507a9c5a47335d86744b508f32419882e77ff4e..879a52cef8ff0b95ae1a21e4e44c30a667b4318f 100755 --- a/ec2/spark_ec2.py +++ b/ec2/spark_ec2.py @@ -809,7 +809,7 @@ def is_cluster_ssh_available(cluster_instances, opts): Check if SSH is available on all the instances in a cluster. """ for i in cluster_instances: - if not is_ssh_available(host=i.ip_address, opts=opts): + if not is_ssh_available(host=i.public_dns_name, opts=opts): return False else: return True