From f65a000f2db72106b2bcaa5f8e84717b0a9700c5 Mon Sep 17 00:00:00 2001
From: wangzejie <wangzejie@sprucetec.com>
Date: Sat, 10 Jun 2017 23:46:58 +0800
Subject: [PATCH] Fixed executor blocked because of traceback.format_exc throw
 UnicodeDecodeError

---
 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 baaa3fe074e9..ce674b6533bb 100644
--- a/python/pyspark/worker.py
+++ b/python/pyspark/worker.py
@@ -178,7 +178,7 @@ def process():
     except Exception:
         try:
             write_int(SpecialLengths.PYTHON_EXCEPTION_THROWN, outfile)
-            write_with_length(traceback.format_exc().encode("utf-8"), outfile)
+            write_with_length(traceback.format_exc(), outfile)
         except IOError:
             # JVM close the socket
             pass