[SPARK-3885] Provide mechanism to remove accumulators once they are no longer used

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.0.2, 1.1.0, 1.2.0
• Fix Version/s: 1.4.0
• Component/s: Spark Core
• Assignee: Ilya Ganelin Assign to me
• Reporter: Josh Rosen
• Created: 09/Oct/14 21:26
• Updated: 28/Feb/15 19:54
• Resolved: 23/Feb/15 06:58

Description

Spark does not currently provide any mechanism to delete accumulators after they are no longer used. This can lead to OOMs for long-lived SparkContexts that create many large accumulators.

Part of the problem is that accumulators are registered in a global Accumulators registry. Maybe the fix would be as simple as using weak references in the Accumulators registry so that accumulators can be GC'd once they can no longer be used.

In the meantime, here's a workaround that users can try:

Accumulators have a public setValue() method that can be called (only by the driver) to change an accumulator’s value. You might be able to use this to reset accumulators’ values to smaller objects (e.g. the “zero” object of whatever your accumulator type is, or ‘null’ if you’re sure that the accumulator will never be accessed again).

This issue was originally reported by Nathan Kronenfeld on the dev mailing list: http://apache-spark-developers-list.1001551.n3.nabble.com/Fwd-Accumulator-question-td8709.html

Issue Links

• is related to: SPARK-4030 `destroy` method in Broadcast should be public
• links to: [Github] Pull Request #4021 (ilganeli)