str.decode（）不适用于pyspark中的中文字符

Question

test_decode = '测试' 
print test_decode.decode('utf-8') 

上面的简单代码可以在本地工作，但在pyspark中运行时无法工作，任何人都知道为什么？在pyspark的错误如下：

Traceback (most recent call last): 
    File "/home/litaotao/Program/TrajectoryPrediction/src/cluster/Tool.py", line 62, in <module> 
    print test_decode.decode('utf-8') 
UnicodeEncodeError: 'ascii' codec can't encode characters in position 0-1: ordinal not in range(128) 

Answer 1

添加代码：

# coding=utf-8 
import sys 
reload(sys) 
sys.setdefaultencoding('utf-8')