flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mbala...@apache.org
Subject flink git commit: [FLINK-4259] Added statement in FileCache to close the FSDataOutputStream object
Date Thu, 28 Jul 2016 17:49:14 GMT
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 <nsalian@cloudera.com>
Authored: Mon Jul 25 13:30:42 2016 -0700
Committer: Marton Balassi <mbalassi@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);


Mime
View raw message