diff --git a/ec2/spark_ec2.py b/ec2/spark_ec2.py index e99fc51805dd6386aa3a1360e36b6f539e45b18b..8ac3241e090b07b92940ce9bd80740add3d2685e 100755 --- a/ec2/spark_ec2.py +++ b/ec2/spark_ec2.py @@ -444,7 +444,7 @@ def setup_cluster(conn, master_nodes, slave_nodes, opts, deploy_ssh_key): # NOTE: We should clone the repository before running deploy_files to # prevent ec2-variables.sh from being overwritten - ssh(master, opts, "rm -rf spark-ec2 && git clone https://github.com/mesos/spark-ec2.git -b v2") + ssh(master, opts, "rm -rf spark-ec2 && git clone https://github.com/mesos/spark-ec2.git -b v3") print "Deploying files to master..." deploy_files(conn, "deploy.generic", opts, master_nodes, slave_nodes, modules)