广播'对象没有属性'destroy'？

Question

在我的 pyspark scirpt 代码中，我声明了一个 Broadcast 变量。最后，我想销毁这个变量，但是得到

Blockquote AttributeError: 'Broadcast' object has no attribute 'destroy'

我的代码是这样的：

br = sc.broadcast(my_value)
rdd.map(__my_map_function) # __my_map_function() used br variable
br.destroy()

我的spark版本是1.6.1，我知道classBroadCast有destroy()方法，但是为什么代码会抛出这个异常？谢谢。

Answer 1

destroy 方法在 spark-2.x.

之前的 pyspark 中不可用

如有疑问，您可以查看 the sources。