diff options
| author | zsxwing <zsxwing@gmail.com> | 2015-08-11 14:06:23 -0700 |
|---|---|---|
| committer | Reynold Xin <rxin@databricks.com> | 2015-08-11 14:06:23 -0700 |
| commit | f16bc68dfb25c7b746ae031a57840ace9bafa87f (patch) | |
| tree | 4d5d61a036b7a0de11eb480fc934fb6bdc526407 /examples | |
| parent | 00c02728a6c6c4282c389ca90641dd78dd5e3d32 (diff) | |
| download | spark-f16bc68dfb25c7b746ae031a57840ace9bafa87f.tar.gz spark-f16bc68dfb25c7b746ae031a57840ace9bafa87f.tar.bz2 spark-f16bc68dfb25c7b746ae031a57840ace9bafa87f.zip | |
[SPARK-9824] [CORE] Fix the issue that InternalAccumulator leaks WeakReference
`InternalAccumulator.create` doesn't call `registerAccumulatorForCleanup` to register itself with ContextCleaner, so `WeakReference`s for these accumulators in `Accumulators.originals` won't be removed.
This PR added `registerAccumulatorForCleanup` for internal accumulators to avoid the memory leak.
Author: zsxwing <zsxwing@gmail.com>
Closes #8108 from zsxwing/internal-accumulators-leak.
Diffstat (limited to 'examples')
0 files changed, 0 insertions, 0 deletions