diff options
| author | Josh Rosen <joshrosen@eecs.berkeley.edu> | 2012-12-28 22:19:12 -0800 |
|---|---|---|
| committer | Josh Rosen <joshrosen@eecs.berkeley.edu> | 2012-12-28 22:21:16 -0800 |
| commit | 7ec3595de28d53839cb3a45e940ec16f81ffdf45 (patch) | |
| tree | 2933cb5d71d76fdcea27125168f346ad38d4fca2 /pyspark/pyspark/java_gateway.py | |
| parent | fbadb1cda504b256e3d12c4ce389e723b6f2503c (diff) | |
| download | spark-7ec3595de28d53839cb3a45e940ec16f81ffdf45.tar.gz spark-7ec3595de28d53839cb3a45e940ec16f81ffdf45.tar.bz2 spark-7ec3595de28d53839cb3a45e940ec16f81ffdf45.zip | |
Fix bug (introduced by batching) in PySpark take()
Diffstat (limited to 'pyspark/pyspark/java_gateway.py')
| -rw-r--r-- | pyspark/pyspark/java_gateway.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/pyspark/pyspark/java_gateway.py b/pyspark/pyspark/java_gateway.py index eb2a875762..2329e536cc 100644 --- a/pyspark/pyspark/java_gateway.py +++ b/pyspark/pyspark/java_gateway.py @@ -30,7 +30,7 @@ def launch_gateway(): sys.stderr.write(line) EchoOutputThread(proc.stdout).start() # Connect to the gateway - gateway = JavaGateway(GatewayClient(port=port)) + gateway = JavaGateway(GatewayClient(port=port), auto_convert=False) # Import the classes used by PySpark java_import(gateway.jvm, "spark.api.java.*") java_import(gateway.jvm, "spark.api.python.*") |