You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by pw...@apache.org on 2014/05/05 06:59:27 UTC
git commit: Address SPARK-1717
Repository: spark
Updated Branches:
refs/heads/master b48a55ae9 -> bb2bb0cf6
Address SPARK-1717
I tested the change locally with Spark 0.9.1, but I can't test with 1.0.0 because there was no AMI for it at the time. It's a trivial fix, so it shouldn't cause any problems.
Author: msiddalingaiah <ma...@madhu.com>
Closes #641 from msiddalingaiah/master and squashes the following commits:
a4f7404 [msiddalingaiah] Address SPARK-1717
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/bb2bb0cf
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/bb2bb0cf
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/bb2bb0cf
Branch: refs/heads/master
Commit: bb2bb0cf6efcb1d18846e6c4904f3cd2da452f9f
Parents: b48a55a
Author: msiddalingaiah <ma...@madhu.com>
Authored: Sun May 4 21:59:10 2014 -0700
Committer: Patrick Wendell <pw...@gmail.com>
Committed: Sun May 4 21:59:10 2014 -0700
----------------------------------------------------------------------
ec2/spark_ec2.py | 6 +++---
1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/bb2bb0cf/ec2/spark_ec2.py
----------------------------------------------------------------------
diff --git a/ec2/spark_ec2.py b/ec2/spark_ec2.py
index 0f6d5a1..0a8d6ca 100755
--- a/ec2/spark_ec2.py
+++ b/ec2/spark_ec2.py
@@ -612,7 +612,7 @@ def ssh_command(opts):
return ['ssh'] + ssh_args(opts)
-# Run a command on a host through ssh, retrying up to two times
+# Run a command on a host through ssh, retrying up to five times
# and then throwing an exception if ssh continues to fail.
def ssh(host, opts, command):
tries = 0
@@ -621,7 +621,7 @@ def ssh(host, opts, command):
return subprocess.check_call(
ssh_command(opts) + ['-t', '-t', '%s@%s' % (opts.user, host), stringify_command(command)])
except subprocess.CalledProcessError as e:
- if (tries > 2):
+ if (tries > 5):
# If this was an ssh failure, provide the user with hints.
if e.returncode == 255:
raise UsageError("Failed to SSH to remote host {0}.\nPlease check that you have provided the correct --identity-file and --key-pair parameters and try again.".format(host))
@@ -648,7 +648,7 @@ def ssh_write(host, opts, command, input):
status = proc.wait()
if status == 0:
break
- elif (tries > 2):
+ elif (tries > 5):
raise RuntimeError("ssh_write failed with error %s" % proc.returncode)
else:
print >> stderr, "Error {0} while executing remote command, retrying after 30 seconds".format(status)