diff options
| author | Stephen Haberman <stephen@exigencecorp.com> | 2013-02-01 10:34:02 -0600 |
|---|---|---|
| committer | Stephen Haberman <stephen@exigencecorp.com> | 2013-02-01 10:34:02 -0600 |
| commit | 59c57e48dfb362923610785b230d5b3b56c620c3 (patch) | |
| tree | 40935b3790b7955b2aba6ea413683c8fc4a9b726 | |
| parent | 55327a283e962652a126d3f8ac7e9a19c76f1f19 (diff) | |
| download | spark-59c57e48dfb362923610785b230d5b3b56c620c3.tar.gz spark-59c57e48dfb362923610785b230d5b3b56c620c3.tar.bz2 spark-59c57e48dfb362923610785b230d5b3b56c620c3.zip | |
Stop BlockManagers metadataCleaner.
| -rw-r--r-- | core/src/main/scala/spark/storage/BlockManager.scala | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/core/src/main/scala/spark/storage/BlockManager.scala b/core/src/main/scala/spark/storage/BlockManager.scala index c61fd75c2b..9893e9625d 100644 --- a/core/src/main/scala/spark/storage/BlockManager.scala +++ b/core/src/main/scala/spark/storage/BlockManager.scala @@ -950,6 +950,7 @@ class BlockManager( blockInfo.clear() memoryStore.clear() diskStore.clear() + metadataCleaner.cancel() logInfo("BlockManager stopped") } } |