diff options
| author | Davies Liu <davies@databricks.com> | 2015-08-13 17:33:37 -0700 |
|---|---|---|
| committer | Davies Liu <davies.liu@gmail.com> | 2015-08-13 17:33:46 -0700 |
| commit | cadc3b7d244558b4867af088dacc53003d8871f8 (patch) | |
| tree | bdaed308c12b79f8f5f2eaabc32b43d1a6e0c073 /python | |
| parent | 2b6b1d12fb6bd0bd86988babc4c807856011f246 (diff) | |
| download | spark-cadc3b7d244558b4867af088dacc53003d8871f8.tar.gz spark-cadc3b7d244558b4867af088dacc53003d8871f8.tar.bz2 spark-cadc3b7d244558b4867af088dacc53003d8871f8.zip | |
[SPARK-8976] [PYSPARK] fix open mode in python3
This bug only happen on Python 3 and Windows.
I tested this manually with python 3 and disable python daemon, no unit test yet.
Author: Davies Liu <davies@databricks.com>
Closes #8181 from davies/open_mode.
(cherry picked from commit 693949ba4096c01a0b41da2542ff316823464a16)
Signed-off-by: Davies Liu <davies.liu@gmail.com>
Diffstat (limited to 'python')
| -rw-r--r-- | python/pyspark/worker.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/python/pyspark/worker.py b/python/pyspark/worker.py index 93df9002be..42c2f8b759 100644 --- a/python/pyspark/worker.py +++ b/python/pyspark/worker.py @@ -146,5 +146,5 @@ if __name__ == '__main__': java_port = int(sys.stdin.readline()) sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM) sock.connect(("127.0.0.1", java_port)) - sock_file = sock.makefile("a+", 65536) + sock_file = sock.makefile("rwb", 65536) main(sock_file, sock_file) |