Repository: reef Updated Branches: refs/heads/master 31fbd0e99 -> 220d75cac
[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 Project: http://git-wip-us.apache.org/repos/asf/reef/repo Commit: http://git-wip-us.apache.org/repos/asf/reef/commit/220d75ca Tree: http://git-wip-us.apache.org/repos/asf/reef/tree/220d75ca Diff: http://git-wip-us.apache.org/repos/asf/reef/diff/220d75ca Branch: refs/heads/master Commit: 220d75cacb49754cfdbac9da54eba4a116c9d1fb Parents: 31fbd0e Author: Mariia Mykhailova <[email protected]> Authored: Tue Nov 1 16:03:05 2016 -0700 Committer: Markus Weimer <[email protected]> Committed: Tue Nov 1 17:25:11 2016 -0700 ---------------------------------------------------------------------- .../yarn/driver/restart/DFSEvaluatorLogOverwriteReaderWriter.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/reef/blob/220d75ca/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 @@ public final class DFSEvaluatorLogOverwriteReaderWriter implements DFSEvaluatorL inputStream = newEntryInputStream; } - IOUtils.copyBytes(inputStream, outputStream, 4096, true); + IOUtils.copyBytes(inputStream, outputStream, 4096, false); } finally { outputStream.hsync(); if (inputStream != null) {
