Details
-
Improvement
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
1.1.0, 1.2.0
-
None
Description
The destroy method in Broadcast.scala https://github.com/apache/spark/blob/master/core/src/main/scala/org/apache/spark/broadcast/Broadcast.scala#L91 is right now marked as private[spark]
This prevents long-running applications from cleaning up memory used by broadcast variables on the driver. Also as broadcast variables are always created with persistence MEMORY_DISK, this slows down jobs when old broadcast variables are flushed to disk.
Making `destroy` public can help applications control the lifetime.
Attachments
Issue Links
- relates to
-
SPARK-3885 Provide mechanism to remove accumulators once they are no longer used
- Resolved
- links to