는 PySpark를 사용하여 목록 재구성기 개체를 피클링 할 수 없습니다.

Question

저는 Python을 처음 접했습니다.

from pyspark.mllib.stat import Statistics 
import random 
data = sc.parallelize([range(100),range(100),random.sample(range(100),100),reversed(range(100))]) 
print(Statistics.corr(data)) 

내가 갖는 : - 어떻게 대처하는 어떤 생각을

는

TypeError: can't pickle listreverseiterator objects

그래서 비 serializeable 개체를 만드는 것 "이 뒤바뀜"다음 코드는 일부 직렬화 문제가있다?

감사합니다.

Answer 1

교체 :

reversed(range(100)) 

list(reversed(range(100))) 

로