在我的pyspark代码中,我声明了一个广播变量。最后,我想销毁这个变量,但是
区块引号AttributeError:“广播”对象没有属性“破坏”
我的代码如下:
br = sc.broadcast(my_value)
rdd.map(__my_map_function) # __my_map_function() used br variable
br.destroy()我的spark版本是1.6.1,而且我知道类BroadCast有code ()方法,但是为什么代码会抛出这个异常呢?谢谢。
发布于 2017-07-19 06:47:09
destroy方法在火花-2.x之前是不可用的。
当你有疑问的时候,你可以看看来源。
https://stackoverflow.com/questions/45182154
复制相似问题