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:37 -0700 |
| commit | 693949ba4096c01a0b41da2542ff316823464a16 (patch) | |
| tree | 1ffb1d6e5088859e084524a9773d8b7488ee1f87 | |
| parent | 6c5858bc65c8a8602422b46bfa9cf0a1fb296b88 (diff) | |
| download | spark-693949ba4096c01a0b41da2542ff316823464a16.tar.gz spark-693949ba4096c01a0b41da2542ff316823464a16.tar.bz2 spark-693949ba4096c01a0b41da2542ff316823464a16.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.
| -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) |