diff --git a/ec2/spark_ec2.py b/ec2/spark_ec2.py index 64b31b9d2e620..44775ea479ece 100755 --- a/ec2/spark_ec2.py +++ b/ec2/spark_ec2.py @@ -699,6 +699,7 @@ def ssh(host, opts, command): time.sleep(30) tries = tries + 1 + # Backported from Python 2.7 for compatiblity with 2.6 (See SPARK-1990) def _check_output(*popenargs, **kwargs): if 'stdout' in kwargs: