TEZ-3648. IFile.Write#close has an extra output stream flush
Project: http://git-wip-us.apache.org/repos/asf/tez/repo Commit: http://git-wip-us.apache.org/repos/asf/tez/commit/a5ffdea6 Tree: http://git-wip-us.apache.org/repos/asf/tez/tree/a5ffdea6 Diff: http://git-wip-us.apache.org/repos/asf/tez/diff/a5ffdea6 Branch: refs/heads/TEZ-1190 Commit: a5ffdea62cd6afc4f4a4e54dc20ff93df10b641f Parents: 518deb6 Author: Jonathan Eagles <[email protected]> Authored: Mon Mar 6 09:42:30 2017 -0600 Committer: Jonathan Eagles <[email protected]> Committed: Mon Mar 6 09:42:42 2017 -0600 ---------------------------------------------------------------------- CHANGES.txt | 1 + .../org/apache/tez/runtime/library/common/sort/impl/IFile.java | 5 +---- 2 files changed, 2 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/tez/blob/a5ffdea6/CHANGES.txt ---------------------------------------------------------------------- diff --git a/CHANGES.txt b/CHANGES.txt index f90a29e..4c28405 100644 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -7,6 +7,7 @@ INCOMPATIBLE CHANGES ALL CHANGES: + TEZ-3648. IFile.Write#close has an extra output stream flush TEZ-3649. AsyncHttpConnection should add StopWatch start. TEZ-3647. Add a setting which lets Tez determine Xmx. TEZ-3644. Cleanup container list stored in AMNode. http://git-wip-us.apache.org/repos/asf/tez/blob/a5ffdea6/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/sort/impl/IFile.java ---------------------------------------------------------------------- diff --git a/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/sort/impl/IFile.java b/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/sort/impl/IFile.java index bcf6ca6..8e3661b 100644 --- a/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/sort/impl/IFile.java +++ b/tez-runtime-library/src/main/java/org/apache/tez/runtime/library/common/sort/impl/IFile.java @@ -214,9 +214,6 @@ public class IFile { //account for header bytes decompressedBytesWritten += HEADER.length; - //Flush the stream - out.flush(); - // Close the underlying stream iff we own it... if (ownOutputStream) { out.close(); @@ -226,7 +223,7 @@ public class IFile { compressedOut.finish(); compressedOut.resetState(); } - // Write the checksum + // Write the checksum and flush the buffer checksumOut.finish(); } //header bytes are already included in rawOut
