Repository: flink Updated Branches: refs/heads/master 185b5f6c6 -> 5d7e949fe
[FLINK-4259] Added statement in FileCache to close the FSDataOutputStream object Closes #2299 Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/5d7e949f Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/5d7e949f Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/5d7e949f Branch: refs/heads/master Commit: 5d7e949fee399aacc51c9aba3f4e51444e1a416a Parents: 185b5f6 Author: Neelesh Srinivas Salian <nsal...@cloudera.com> Authored: Mon Jul 25 13:30:42 2016 -0700 Committer: Marton Balassi <mbala...@apache.org> Committed: Thu Jul 28 10:48:46 2016 -0700 ---------------------------------------------------------------------- .../main/java/org/apache/flink/runtime/filecache/FileCache.java | 2 ++ 1 file changed, 2 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/5d7e949f/flink-runtime/src/main/java/org/apache/flink/runtime/filecache/FileCache.java ---------------------------------------------------------------------- diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/filecache/FileCache.java b/flink-runtime/src/main/java/org/apache/flink/runtime/filecache/FileCache.java index 99ed934..b5bdcaf 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/filecache/FileCache.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/filecache/FileCache.java @@ -259,6 +259,8 @@ public class FileCache { IOUtils.copyBytes(fsInput, lfsOutput); //noinspection ResultOfMethodCallIgnored new File(targetPath.toString()).setExecutable(executable); + // closing the FSDataOutputStream + lfsOutput.close(); } catch (IOException ioe) { LOG.error("could not copy file to local file cache.", ioe);
