tez-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From zhiyu...@apache.org
Subject [28/50] [abbrv] tez git commit: TEZ-3648. IFile.Write#close has an extra output stream flush
Date Tue, 28 Mar 2017 19:48:09 GMT
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 <jeagles@yahoo-inc.com>
Authored: Mon Mar 6 09:42:30 2017 -0600
Committer: Jonathan Eagles <jeagles@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


Mime
View raw message