Repository: spark Updated Branches: refs/heads/branch-1.2 790c8741e -> d1d6de630
[SPARK-4441] Close Tachyon client when TachyonBlockManager is shutdown Currently Tachyon client is not closed when TachyonBlockManager is shut down. which causes some resources in Tachyon not reclaimed Author: Mingfei <[email protected]> Closes #3299 from shimingfei/closeClient and squashes the following commits: 0913fbd [Mingfei] close Tachyon client when TachyonBlockManager is shutdown (cherry picked from commit 67e9876b3e457b151c123fdb5ac2d8e8371e6acf) Signed-off-by: Patrick Wendell <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/d1d6de63 Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/d1d6de63 Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/d1d6de63 Branch: refs/heads/branch-1.2 Commit: d1d6de630faad23f5f88f6c5a254720546d97c72 Parents: 790c874 Author: Mingfei <[email protected]> Authored: Tue Nov 18 22:16:36 2014 -0800 Committer: Patrick Wendell <[email protected]> Committed: Tue Nov 18 22:16:45 2014 -0800 ---------------------------------------------------------------------- .../main/scala/org/apache/spark/storage/TachyonBlockManager.scala | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/spark/blob/d1d6de63/core/src/main/scala/org/apache/spark/storage/TachyonBlockManager.scala ---------------------------------------------------------------------- diff --git a/core/src/main/scala/org/apache/spark/storage/TachyonBlockManager.scala b/core/src/main/scala/org/apache/spark/storage/TachyonBlockManager.scala index 6908a59..af87303 100644 --- a/core/src/main/scala/org/apache/spark/storage/TachyonBlockManager.scala +++ b/core/src/main/scala/org/apache/spark/storage/TachyonBlockManager.scala @@ -148,6 +148,7 @@ private[spark] class TachyonBlockManager( logError("Exception while deleting tachyon spark dir: " + tachyonDir, e) } } + client.close() } }) } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
