Merge pull request #196 from pwendell/master TimeTrackingOutputStream should pass on calls to close() and flush().
Without this fix you get a huge number of open files when running shuffles. Project: http://git-wip-us.apache.org/repos/asf/incubator-spark/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-spark/commit/f20093c3 Tree: http://git-wip-us.apache.org/repos/asf/incubator-spark/tree/f20093c3 Diff: http://git-wip-us.apache.org/repos/asf/incubator-spark/diff/f20093c3 Branch: refs/heads/master Commit: f20093c3afa68439b1c9010de189d497df787c2a Parents: 2fead51 53b94ef Author: Reynold Xin <[email protected]> Authored: Fri Nov 22 10:12:13 2013 +0800 Committer: Reynold Xin <[email protected]> Committed: Fri Nov 22 10:12:13 2013 +0800 ---------------------------------------------------------------------- .../main/scala/org/apache/spark/storage/BlockObjectWriter.scala | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-spark/blob/f20093c3/core/src/main/scala/org/apache/spark/storage/BlockObjectWriter.scala ----------------------------------------------------------------------
