Repository: spark Updated Branches: refs/heads/branch-1.5 2b6b1d12f -> cadc3b7d2
[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 <[email protected]> Closes #8181 from davies/open_mode. (cherry picked from commit 693949ba4096c01a0b41da2542ff316823464a16) Signed-off-by: Davies Liu <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/cadc3b7d Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/cadc3b7d Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/cadc3b7d Branch: refs/heads/branch-1.5 Commit: cadc3b7d244558b4867af088dacc53003d8871f8 Parents: 2b6b1d1 Author: Davies Liu <[email protected]> Authored: Thu Aug 13 17:33:37 2015 -0700 Committer: Davies Liu <[email protected]> Committed: Thu Aug 13 17:33:46 2015 -0700 ---------------------------------------------------------------------- python/pyspark/worker.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/spark/blob/cadc3b7d/python/pyspark/worker.py ---------------------------------------------------------------------- diff --git a/python/pyspark/worker.py b/python/pyspark/worker.py index 93df900..42c2f8b 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) --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
