You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@reef.apache.org by we...@apache.org on 2016/11/02 00:26:35 UTC
reef git commit: [REEF-1660] Don't close streams in
DFSEvaluatorLogOverwriteReaderWriter before flushing them
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 <ma...@apache.org>
Authored: Tue Nov 1 16:03:05 2016 -0700
Committer: Markus Weimer <we...@apache.org>
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) {