Repository: spark Updated Branches: refs/heads/master 67e9876b3 -> 165cec9c4
[Spark-4432]close InStream after the block is accessed InStream is not closed after data is read from Tachyon. which makes the blocks in Tachyon locked after accessed. Author: Mingfei <[email protected]> Closes #3290 from shimingfei/lockFix and squashes the following commits: fffe345 [Mingfei] close InStream after the block is accessed Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/165cec9c Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/165cec9c Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/165cec9c Branch: refs/heads/master Commit: 165cec9c468d9dcf5e83f6d43cbb512a98da846c Parents: 67e9876 Author: Mingfei <[email protected]> Authored: Tue Nov 18 22:17:06 2014 -0800 Committer: Patrick Wendell <[email protected]> Committed: Tue Nov 18 22:17:06 2014 -0800 ---------------------------------------------------------------------- core/src/main/scala/org/apache/spark/storage/TachyonStore.scala | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/spark/blob/165cec9c/core/src/main/scala/org/apache/spark/storage/TachyonStore.scala ---------------------------------------------------------------------- diff --git a/core/src/main/scala/org/apache/spark/storage/TachyonStore.scala b/core/src/main/scala/org/apache/spark/storage/TachyonStore.scala index 6dbad5f..233d1e2 100644 --- a/core/src/main/scala/org/apache/spark/storage/TachyonStore.scala +++ b/core/src/main/scala/org/apache/spark/storage/TachyonStore.scala @@ -116,6 +116,8 @@ private[spark] class TachyonStore( case ioe: IOException => logWarning(s"Failed to fetch the block $blockId from Tachyon", ioe) None + } finally { + is.close() } } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
