You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by pr...@apache.org on 2016/04/23 00:55:07 UTC

[3/3] hive git commit: HIVE-13232: Aggressively drop compression buffers in ORC OutStreams (Owen O'Malley reviewed by Prasanth Jayachandran)

HIVE-13232: Aggressively drop compression buffers in ORC OutStreams (Owen O'Malley reviewed by Prasanth Jayachandran)


Project: http://git-wip-us.apache.org/repos/asf/hive/repo
Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/edf89a6a
Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/edf89a6a
Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/edf89a6a

Branch: refs/heads/branch-1
Commit: edf89a6a0b92e3fa2d68096d93a11adfe4353937
Parents: 9a2bd0c
Author: Prasanth Jayachandran <pr...@apache.org>
Authored: Fri Apr 22 17:54:58 2016 -0500
Committer: Prasanth Jayachandran <pr...@apache.org>
Committed: Fri Apr 22 17:54:58 2016 -0500

----------------------------------------------------------------------
 .../apache/hadoop/hive/ql/io/orc/OutStream.java |    2 +-
 .../hadoop/hive/ql/io/orc/TestOrcFile.java.orig | 2034 ------------------
 .../hadoop/hive/ql/io/orc/TestOutStream.java    |   41 +
 3 files changed, 42 insertions(+), 2035 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/hive/blob/edf89a6a/ql/src/java/org/apache/hadoop/hive/ql/io/orc/OutStream.java
----------------------------------------------------------------------
diff --git a/ql/src/java/org/apache/hadoop/hive/ql/io/orc/OutStream.java b/ql/src/java/org/apache/hadoop/hive/ql/io/orc/OutStream.java
index ef1b6b6..e2096eb 100644
--- a/ql/src/java/org/apache/hadoop/hive/ql/io/orc/OutStream.java
+++ b/ql/src/java/org/apache/hadoop/hive/ql/io/orc/OutStream.java
@@ -240,8 +240,8 @@ class OutStream extends PositionedOutputStream {
     if (compressed != null && compressed.position() != 0) {
       compressed.flip();
       receiver.output(compressed);
-      compressed = null;
     }
+    compressed = null;
     uncompressedBytes = 0;
     compressedBytes = 0;
     overflow = null;