磚

x =[1, 2, 3, 4, 5, 6, 7]抽樣= sc.parallelize (x)打印(rdd.take(2)回溯(最近的電話最後):文件“/ usr /地方/火花/ python / pyspark /序列化器。py”, 458行,在轉儲cloudpickle返回。轉儲(obj pickle_protocol) ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^……

回溯(最近調用最後):文件“/ usr /地方/火花/ python / pyspark /序列化器。py”, 458行,在轉儲cloudpickle返回。轉儲(obj pickle_protocol) ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^ ^文件“/ usr /地方/火花/ python / pyspa……