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 @@ private static OrcTail extractFileTail(FileSystem fs, int bufferSize) throws IOException { bb.position(footerAbsPos); bb.limit(footerAbsPos + footerSize); - InputStream instream = InStream.create("footer", + CodedInputStream in = InStream.createCodedInputStream("footer", Lists.newArrayList(new BufferChunk(bb, 0)), footerSize, codec, bufferSize); - CodedInputStream in = CodedInputStream.newInstance(instream); return OrcProto.Footer.parseFrom(in); } @@ -465,9 +464,8 @@ private static OrcTail extractFileTail(FileSystem fs, 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.newArrayList(new BufferChunk(bb, 0)), metadataSize, codec, bufferSize); - CodedInputStream in = CodedInputStream.newInstance(inputStream); return OrcProto.Metadata.parseFrom(in); }