aboutsummaryrefslogtreecommitdiff
path: root/ec2
diff options
context:
space:
mode:
authorDenny <dennybritz@gmail.com>2012-08-14 09:26:47 -0700
committerDenny <dennybritz@gmail.com>2012-08-14 09:26:47 -0700
commit7152c7c12d8767c3f46c1baa2ae7346f2f824c67 (patch)
tree975ed82c888ad1d6caaa2d8ab972a0d228afbf68 /ec2
parent942e604c624d442bb6a754a7143fdab3b14c37e9 (diff)
downloadspark-7152c7c12d8767c3f46c1baa2ae7346f2f824c67.tar.gz
spark-7152c7c12d8767c3f46c1baa2ae7346f2f824c67.tar.bz2
spark-7152c7c12d8767c3f46c1baa2ae7346f2f824c67.zip
rsync root directory in EC2 script
Diffstat (limited to 'ec2')
-rwxr-xr-xec2/spark_ec2.py2
1 files changed, 1 insertions, 1 deletions
diff --git a/ec2/spark_ec2.py b/ec2/spark_ec2.py
index 971b0c6ad7..755261bd54 100755
--- a/ec2/spark_ec2.py
+++ b/ec2/spark_ec2.py
@@ -448,7 +448,7 @@ def deploy_files(conn, root_dir, opts, master_nodes, slave_nodes, zoo_nodes):
dest.close()
# rsync the whole directory over to the master machine
command = (("rsync -rv -e 'ssh -o StrictHostKeyChecking=no -i %s' " +
- "'%s/' '%s@%s:~'") % (opts.identity_file, tmp_dir, opts.user, active_master))
+ "'%s/' '%s@%s:/'") % (opts.identity_file, tmp_dir, opts.user, active_master))
subprocess.check_call(command, shell=True)
# Remove the temp directory we created above
shutil.rmtree(tmp_dir)