Skip to content
Snippets Groups Projects
Commit 165cec9c authored by Mingfei's avatar Mingfei Committed by Patrick Wendell
Browse files

[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
parent 67e9876b
No related branches found
No related tags found
No related merge requests found
...@@ -116,6 +116,8 @@ private[spark] class TachyonStore( ...@@ -116,6 +116,8 @@ private[spark] class TachyonStore(
case ioe: IOException => case ioe: IOException =>
logWarning(s"Failed to fetch the block $blockId from Tachyon", ioe) logWarning(s"Failed to fetch the block $blockId from Tachyon", ioe)
None None
} finally {
is.close()
} }
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment