You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by jo...@apache.org on 2015/04/07 08:52:39 UTC

spark git commit: [SPARK-6636] Use public DNS hostname everywhere in spark_ec2.py

Repository: spark
Updated Branches:
  refs/heads/master a0846c4b6 -> 6f0d55d76


[SPARK-6636] Use public DNS hostname everywhere in spark_ec2.py

The spark_ec2.py script uses public_dns_name everywhere in the script except for testing ssh availability, which is done using the public ip address of the instances. This breaks the script for users who are deploying the cluster with a private-network-only security group. The fix is to use public_dns_name in the remaining place.

Author: Matt Aasted <aa...@twitch.tv>

Closes #5302 from aasted/master and squashes the following commits:

60cf6ee [Matt Aasted] [SPARK-6636] Use public DNS hostname everywhere in spark_ec2.py


Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/6f0d55d7
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/6f0d55d7
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/6f0d55d7

Branch: refs/heads/master
Commit: 6f0d55d76f758d217fd18ffa0ccf273d7ab0377b
Parents: a0846c4
Author: Matt Aasted <aa...@twitch.tv>
Authored: Mon Apr 6 23:50:48 2015 -0700
Committer: Josh Rosen <jo...@databricks.com>
Committed: Mon Apr 6 23:51:47 2015 -0700

----------------------------------------------------------------------
 ec2/spark_ec2.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/spark/blob/6f0d55d7/ec2/spark_ec2.py
----------------------------------------------------------------------
diff --git a/ec2/spark_ec2.py b/ec2/spark_ec2.py
index 5507a9c..879a52c 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


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org