aboutsummaryrefslogtreecommitdiff
path: root/core
diff options
context:
space:
mode:
authorMingfei <mingfei.shi@intel.com>2014-11-18 22:17:06 -0800
committerPatrick Wendell <pwendell@gmail.com>2014-11-18 22:17:35 -0800
commite0a20994f4deead62b4c038500bb1a98992f9974 (patch)
tree5867ef1cbded90644418392d4a1d17103540de70 /core
parentd1d6de630faad23f5f88f6c5a254720546d97c72 (diff)
downloadspark-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.scala2
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()
}
}