Repository: hive Updated Branches: refs/heads/branch-1 e8d71a22c -> 46c847968
HIVE-14084: Branch-1: HIVE-13985 backport to branch-1 introduced regression (Prasanth Jayachandran reviewed by Sergey Shelukhin) Project: http://git-wip-us.apache.org/repos/asf/hive/repo Commit: http://git-wip-us.apache.org/repos/asf/hive/commit/46c84796 Tree: http://git-wip-us.apache.org/repos/asf/hive/tree/46c84796 Diff: http://git-wip-us.apache.org/repos/asf/hive/diff/46c84796 Branch: refs/heads/branch-1 Commit: 46c8479685a2a7ab9a77ff54e12f11bfaaebd84a Parents: e8d71a2 Author: Prasanth Jayachandran <[email protected]> Authored: Thu Jun 23 15:17:00 2016 -0700 Committer: Prasanth Jayachandran <[email protected]> Committed: Thu Jun 23 15:17:00 2016 -0700 ---------------------------------------------------------------------- ql/src/java/org/apache/hadoop/hive/ql/io/orc/ReaderImpl.java | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/hive/blob/46c84796/ql/src/java/org/apache/hadoop/hive/ql/io/orc/ReaderImpl.java ---------------------------------------------------------------------- diff --git a/ql/src/java/org/apache/hadoop/hive/ql/io/orc/ReaderImpl.java b/ql/src/java/org/apache/hadoop/hive/ql/io/orc/ReaderImpl.java index 1b7f6d6..30a3f6a 100644 --- a/ql/src/java/org/apache/hadoop/hive/ql/io/orc/ReaderImpl.java +++ b/ql/src/java/org/apache/hadoop/hive/ql/io/orc/ReaderImpl.java @@ -455,9 +455,8 @@ public class ReaderImpl implements Reader { int bufferSize) throws IOException { bb.position(footerAbsPos); bb.limit(footerAbsPos + footerSize); - InputStream instream = InStream.create("footer", + CodedInputStream in = InStream.createCodedInputStream("footer", Lists.<DiskRange>newArrayList(new BufferChunk(bb, 0)), footerSize, codec, bufferSize); - CodedInputStream in = CodedInputStream.newInstance(instream); return OrcProto.Footer.parseFrom(in); } @@ -465,9 +464,8 @@ public class ReaderImpl implements Reader { int metadataSize, CompressionCodec codec, int bufferSize) throws IOException { bb.position(metadataAbsPos); bb.limit(metadataAbsPos + metadataSize); - InputStream inputStream = InStream.create("metadata", + CodedInputStream in = InStream.createCodedInputStream("metadata", Lists.<DiskRange>newArrayList(new BufferChunk(bb, 0)), metadataSize, codec, bufferSize); - CodedInputStream in = CodedInputStream.newInstance(inputStream); return OrcProto.Metadata.parseFrom(in); }
