From 693949ba4096c01a0b41da2542ff316823464a16 Mon Sep 17 00:00:00 2001
From: Davies Liu <davies@databricks.com>
Date: Thu, 13 Aug 2015 17:33:37 -0700
Subject: [PATCH] [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.
---
python/pyspark/worker.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
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)
--
GitLab