回溯(最近調用最後):文件“/ usr /地方/火花/ python / pyspark /序列化器。py”, 458行,在轉儲cloudpickle返回。轉儲(obj pickle_protocol) ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^文件“/ usr /本地/火花/ python / pyspark / cloudpickle / cloudpickle_fast。py”, 73行,在轉儲cp.dump (obj)文件“/ usr /地方/火花/ python / pyspark / cloudpickle / cloudpickle_fast。py”, 602行,在轉儲返回酸洗液。轉儲(自我,obj) ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^文件“/ usr /本地/火花/ python / pyspark / cloudpickle / cloudpickle_fast。py”, 692行,在reducer_override返回self._function_reduce (obj) ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^”文件/ usr /地方/火花/ python / pyspark / cloudpickle / cloudpickle_fast。py”, 565行,在_function_reduce返回self._dynamic_function_reduce (obj) ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^
操作:
x = [1, 2, 3, 4, 5, 6, 7]
抽樣= sc.parallelize (x)
打印(rdd.take (2))
