Repository: spark Updated Branches: refs/heads/branch-0.9 8e9f479ed -> 2a2eacef4
HOTFIX: bug caused by #941 This patch should have qualified the use of PIPE. This needs to be back ported into 0.9 and 1.0. Author: Patrick Wendell <[email protected]> Closes #1108 from pwendell/hotfix and squashes the following commits: 711c58d [Patrick Wendell] HOTFIX: bug caused by #941 (cherry picked from commit b2ebf429e24566c29850c570f8d76943151ad78c) Signed-off-by: Xiangrui Meng <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/2a2eacef Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/2a2eacef Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/2a2eacef Branch: refs/heads/branch-0.9 Commit: 2a2eacef4b469beb7d499c29baff9d6f52d0e25e Parents: 8e9f479 Author: Patrick Wendell <[email protected]> Authored: Tue Jun 17 15:09:24 2014 -0700 Committer: Xiangrui Meng <[email protected]> Committed: Tue Jun 17 15:09:55 2014 -0700 ---------------------------------------------------------------------- ec2/spark_ec2.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/spark/blob/2a2eacef/ec2/spark_ec2.py ---------------------------------------------------------------------- diff --git a/ec2/spark_ec2.py b/ec2/spark_ec2.py index 8f6a69c..6d06a5d 100755 --- a/ec2/spark_ec2.py +++ b/ec2/spark_ec2.py @@ -633,7 +633,7 @@ def ssh(host, opts, command): def _check_output(*popenargs, **kwargs): if 'stdout' in kwargs: raise ValueError('stdout argument not allowed, it will be overridden.') - process = subprocess.Popen(stdout=PIPE, *popenargs, **kwargs) + process = subprocess.Popen(stdout=subprocess.PIPE, *popenargs, **kwargs) output, unused_err = process.communicate() retcode = process.poll() if retcode:
