Github user asfgit closed the pull request at:
https://github.com/apache/spark/pull/18277
---
-
To unsubscribe, e-mail: reviews-unsubscr...@spark.apache.org
For additional commands, e-mail: reviews-h...@spark.apache.org
Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/18277#discussion_r162782791
--- Diff: python/pyspark/rdd.py ---
@@ -751,7 +751,7 @@ def func(iterator):
def pipe_objs(out):
for obj in
Github user HyukjinKwon commented on a diff in the pull request:
https://github.com/apache/spark/pull/18277#discussion_r121589809
--- Diff: python/pyspark/rdd.py ---
@@ -751,7 +751,7 @@ def func(iterator):
def pipe_objs(out):
for obj in
GitHub user chaoslawful opened a pull request:
https://github.com/apache/spark/pull/18277
[SPARK-20947][PYTHON] Fix encoding/decoding error in pipe action
## What changes were proposed in this pull request?
Pipe action convert objects into strings using a way that was