diff options
author | Mingfei <mingfei.shi@intel.com> | 2014-11-18 22:17:06 -0800 |
---|---|---|
committer | Patrick Wendell <pwendell@gmail.com> | 2014-11-18 22:17:35 -0800 |
commit | e0a20994f4deead62b4c038500bb1a98992f9974 (patch) | |
tree | 5867ef1cbded90644418392d4a1d17103540de70 /core | |
parent | d1d6de630faad23f5f88f6c5a254720546d97c72 (diff) | |
download | spark-e0a20994f4deead62b4c038500bb1a98992f9974.tar.gz spark-e0a20994f4deead62b4c038500bb1a98992f9974.tar.bz2 spark-e0a20994f4deead62b4c038500bb1a98992f9974.zip |
[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 <mingfei.shi@intel.com>
Closes #3290 from shimingfei/lockFix and squashes the following commits:
fffe345 [Mingfei] close InStream after the block is accessed
Diffstat (limited to 'core')
-rw-r--r-- | core/src/main/scala/org/apache/spark/storage/TachyonStore.scala | 2 |
1 files changed, 2 insertions, 0 deletions
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 6dbad5ff05..233d1e2b7c 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() } } |