commit 220d75cacb49754cfdbac9da54eba4a116c9d1fb
author Mariia Mykhailova <mariia@apache.org> Tue Nov 01 16:03:05 2016 -0700
committer Markus Weimer <weimer@apache.org> Tue Nov 01 17:25:11 2016 -0700
tree 052c404a7f01550472d632ad8df94e00796bf898
parent 31fbd0e997534f14ec826470e838deda3ea6012f

[REEF-1660] Don't close streams in DFSEvaluatorLogOverwriteReaderWriter before flushing them

This change removes closing streams in call to IOUtils.copyBytes.
This way outputStream is synced while it's still open, so sync operation doesn't
fail.

JIRA:
  [REEF-1660](https://issues.apache.org/jira/browse/REEF-1660)

Pull request:
  This closes #1176

lang/java/reef-runtime-yarn/src/main/java/org/apache/reef/runtime/yarn/driver/restart/DFSEvaluatorLogOverwriteReaderWriter.java

diff --git a/lang/java/reef-runtime-yarn/src/main/java/org/apache/reef/runtime/yarn/driver/restart/DFSEvaluatorLogOverwriteReaderWriter.java b/lang/java/reef-runtime-yarn/src/main/java/org/apache/reef/runtime/yarn/driver/restart/DFSEvaluatorLogOverwriteReaderWriter.java
index 3518fb5..e647ef0 100644
--- a/lang/java/reef-runtime-yarn/src/main/java/org/apache/reef/runtime/yarn/driver/restart/DFSEvaluatorLogOverwriteReaderWriter.java
+++ b/lang/java/reef-runtime-yarn/src/main/java/org/apache/reef/runtime/yarn/driver/restart/DFSEvaluatorLogOverwriteReaderWriter.java
@@ -82,7 +82,7 @@
           inputStream = newEntryInputStream;
         }
 
-        IOUtils.copyBytes(inputStream, outputStream, 4096, true);
+        IOUtils.copyBytes(inputStream, outputStream, 4096, false);
       } finally {
         outputStream.hsync();
         if (inputStream != null) {