You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tez.apache.org by je...@apache.org on 2017/03/06 15:43:15 UTC
tez git commit: TEZ-3648. IFile.Write#close has an extra output
stream flush
Repository: tez
Updated Branches:
refs/heads/master 518deb6c2 -> a5ffdea62
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/master
Commit: a5ffdea62cd6afc4f4a4e54dc20ff93df10b641f
Parents: 518deb6
Author: Jonathan Eagles <je...@yahoo-inc.com>
Authored: Mon Mar 6 09:42:30 2017 -0600
Committer: Jonathan Eagles <je...@yahoo-inc.com>
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