[SPARK-20947][PYTHON] Fix encoding/decoding error in pipe action

apache · Jun 12, 2017 · 1b13e34 · 1b13e34
1 parent d140918
commit 1b13e34
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/python/pyspark/rdd.py b/python/pyspark/rdd.py
@@ -751,7 +751,7 @@ def func(iterator):
 
             def pipe_objs(out):
                 for obj in iterator:
-                    s = str(obj).rstrip('\n') + '\n'
+                    s = unicode(obj).rstrip('\n') + '\n'
                     out.write(s.encode('utf-8'))
                 out.close()
             Thread(target=pipe_objs, args=[pipe.stdin]).start()