Description
To prevent opened file leakage, we need to move the file open position.
--- a/java/core/src/java/org/apache/orc/impl/ReaderImpl.java long maxFileLength) throws IOException { - FSDataInputStream file = fs.open(path); + FSDataInputStream file = null; ByteBuffer buffer; OrcProto.PostScript ps; OrcProto.FileTail.Builder fileTailBuilder = OrcProto.FileTail.newBuilder(); long modificationTime; try { + file = fs.open(path);
Attachments
Issue Links
- links to