diff --git llap-server/src/java/org/apache/hadoop/hive/llap/io/encoded/OrcEncodedDataReader.java llap-server/src/java/org/apache/hadoop/hive/llap/io/encoded/OrcEncodedDataReader.java index eb8ee6c..c0a87ee 100644 --- llap-server/src/java/org/apache/hadoop/hive/llap/io/encoded/OrcEncodedDataReader.java +++ llap-server/src/java/org/apache/hadoop/hive/llap/io/encoded/OrcEncodedDataReader.java @@ -30,6 +30,7 @@ import org.apache.orc.TypeDescription; import org.apache.orc.impl.DataReaderProperties; import org.apache.orc.impl.OrcIndex; +import org.apache.orc.impl.OrcTail; import org.apache.orc.impl.SchemaEvolution; import org.apache.tez.common.counters.TezCounters; import org.slf4j.Logger; @@ -589,6 +590,13 @@ private void ensureOrcReader() throws IOException { LlapIoImpl.ORC_LOGGER.trace("Creating reader for {} ({})", path, split.getPath()); long startTime = counters.startTimeCounter(); ReaderOptions opts = OrcFile.readerOptions(conf).filesystem(fs).fileMetadata(fileMetadata); + if (split instanceof OrcSplit) { + OrcTail orcTail = ((OrcSplit) split).getOrcTail(); + if (orcTail != null) { + LOG.debug("Setting OrcTail. path={}", path); + opts.orcTail(orcTail); + } + } orcReader = EncodedOrcFile.createReader(path, opts); counters.incrTimeCounter(LlapIOCounters.HDFS_TIME_NS, startTime); }