diff options
| author | Josh Rosen <joshrosen@eecs.berkeley.edu> | 2012-12-28 09:06:11 -0800 |
|---|---|---|
| committer | Josh Rosen <joshrosen@eecs.berkeley.edu> | 2012-12-28 09:06:11 -0800 |
| commit | fbadb1cda504b256e3d12c4ce389e723b6f2503c (patch) | |
| tree | c235173f12e4edd97940681a52f099b6bf6570e8 /pyspark | |
| parent | 665466dfff4f89196627a0777eabd3d3894cd296 (diff) | |
| download | spark-fbadb1cda504b256e3d12c4ce389e723b6f2503c.tar.gz spark-fbadb1cda504b256e3d12c4ce389e723b6f2503c.tar.bz2 spark-fbadb1cda504b256e3d12c4ce389e723b6f2503c.zip | |
Mark api.python classes as private; echo Java output to stderr.
Diffstat (limited to 'pyspark')
| -rw-r--r-- | pyspark/pyspark/java_gateway.py | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/pyspark/pyspark/java_gateway.py b/pyspark/pyspark/java_gateway.py index d4a4434c05..eb2a875762 100644 --- a/pyspark/pyspark/java_gateway.py +++ b/pyspark/pyspark/java_gateway.py @@ -1,4 +1,5 @@ import os +import sys from subprocess import Popen, PIPE from threading import Thread from py4j.java_gateway import java_import, JavaGateway, GatewayClient @@ -26,7 +27,7 @@ def launch_gateway(): def run(self): while True: line = self.stream.readline() - print line, + sys.stderr.write(line) EchoOutputThread(proc.stdout).start() # Connect to the gateway gateway = JavaGateway(GatewayClient(port=port)) |