| commit | 5d7e949fee399aacc51c9aba3f4e51444e1a416a | [log] [tgz] |
|---|---|---|
| author | Neelesh Srinivas Salian <nsalian@cloudera.com> | Mon Jul 25 13:30:42 2016 -0700 |
| committer | Marton Balassi <mbalassi@apache.org> | Thu Jul 28 10:48:46 2016 -0700 |
| tree | ef9d6bee603622ca643daa3ad12a6b5821bda10a | |
| parent | 185b5f6c6b91e4ae61ff77c7d22d1296153a320c [diff] |
[FLINK-4259] Added statement in FileCache to close the FSDataOutputStream object Closes #2299
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 @@ 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);