HOTFIX: bug caused by apache#941

pwendell · mengxr · commit 2a2eacef4b46 · 2014-06-17T15:09:55.000-07:00
This patch should have qualified the use of PIPE. This needs to be back ported into 0.9 and 1.0. Author: Patrick Wendell <pwendell@gmail.com> Closes apache#1108 from pwendell/hotfix and squashes the following commits: 711c58d [Patrick Wendell] HOTFIX: bug caused by apache#941 (cherry picked from commit b2ebf42) Signed-off-by: Xiangrui Meng <meng@databricks.com>
diff --git 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:
